Posts

Showing posts from November, 2022

Service account token

1. => tạo service account kubectl create serviceaccount deployer 2. => tạo binding giữa service accounts và role-admin kubectl create clusterrolebinding deployer-binding --clusterrole=cluster-admin \ --serviceaccount= default :deployer 3. => Tạo token với name deployer-secret và attach vào service account deployer kubectl apply -f - <<EOF apiVersion: v1 kind: Secret metadata: name: deployer-secret annotations: kubernetes.io/service-account.name: deployer type: kubernetes.io/ service-account-token EOF 4. => hiển thị danh sách tên các token đã được tạo ra kubectl get secrets 5. => view token value cho deployer đã tạo kubectl describe secret deployer-token-nmx8l https: //cloudhedge.io/setting-up-kubernetes-api-access-using-service-account/

Emit Events with sink

  private final Sinks.Many<String> eventSink = Sinks. many ().multicast().directBestEffort() ; @GetMapping (value = "/{id}" , produces = MediaType. TEXT_EVENT_STREAM_VALUE ) public Flux<ServerSentEvent<String>> sse ( @PathVariable ( "id" ) String id) { final AtomicLong counter = new AtomicLong( 0 ) ; return eventSink .asFlux() .filter(e -> e.equals( id )) .map(e -> { System. out .println(Thread. currentThread ().getName()) ; return ServerSentEvent. builder (e) .id( counter .incrementAndGet() + "" ) .event(e.toLowerCase() + "-" + new SimpleDateFormat( "yyyy.MM.dd.HH.mm.ss" ).format( new java.util.Date())) .build() ; }) ; } @ResponseStatus (HttpStatus. OK ) @ResponseBody ...