v1

Documentation

Index

• Variables
• func RegisterCallbackServiceServer(s grpc.ServiceRegistrar, srv CallbackServiceServer)
• type CallbackServiceClient
  • func NewCallbackServiceClient(cc grpc.ClientConnInterface) CallbackServiceClient
• type CallbackServiceServer
• type ChallengeRequest
  • func (*ChallengeRequest) Descriptor() ([]byte, []int)
  • func (x *ChallengeRequest) GetChallengeId() string
  • func (x *ChallengeRequest) GetChallengeRandom() []byte
  • func (*ChallengeRequest) ProtoMessage()
  • func (x *ChallengeRequest) ProtoReflect() protoreflect.Message
  • func (x *ChallengeRequest) Reset()
  • func (x *ChallengeRequest) String() string
• type ChallengeResponse
  • func (*ChallengeResponse) Descriptor() ([]byte, []int)
  • func (x *ChallengeResponse) GetChallengeResponse() []byte
  • func (*ChallengeResponse) ProtoMessage()
  • func (x *ChallengeResponse) ProtoReflect() protoreflect.Message
  • func (x *ChallengeResponse) Reset()
  • func (x *ChallengeResponse) String() string
• type UnimplementedCallbackServiceServer
  • func (UnimplementedCallbackServiceServer) Challenge(context.Context, *ChallengeRequest) (*ChallengeResponse, error)
• type UnsafeCallbackServiceServer

Variables

var CallbackService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kops.bootstrap.v1.CallbackService",
	HandlerType: (*CallbackServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Challenge",
			Handler:    _CallbackService_Challenge_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kops/bootstrap/v1/bootstrap.proto",
}

CallbackService_ServiceDesc is the grpc.ServiceDesc for CallbackService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var File_kops_bootstrap_v1_bootstrap_proto protoreflect.FileDescriptor

Functions

func RegisterCallbackServiceServer

func RegisterCallbackServiceServer(s grpc.ServiceRegistrar, srv CallbackServiceServer)

Types

type CallbackServiceClient

type CallbackServiceClient interface {
	// Answers challenges to cross-check bootstrap requests.
	Challenge(ctx context.Context, in *ChallengeRequest, opts ...grpc.CallOption) (*ChallengeResponse, error)
}

CallbackServiceClient is the client API for CallbackService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCallbackServiceClient

func NewCallbackServiceClient(cc grpc.ClientConnInterface) CallbackServiceClient

type CallbackServiceServer

type CallbackServiceServer interface {
	// Answers challenges to cross-check bootstrap requests.
	Challenge(context.Context, *ChallengeRequest) (*ChallengeResponse, error)
	// contains filtered or unexported methods
}

CallbackServiceServer is the server API for CallbackService service. All implementations must embed UnimplementedCallbackServiceServer for forward compatibility

type ChallengeRequest

type ChallengeRequest struct {

	// challenge_id is a random value (nonce) that the node generated and passed in its bootstrap request.
	ChallengeId string `protobuf:"bytes,1,opt,name=challenge_id,json=challengeId,proto3" json:"challenge_id,omitempty"`
	// challenge_random is a random value (nonce) that kops-controller generated, it is hashed into the response.
	ChallengeRandom []byte `protobuf:"bytes,2,opt,name=challenge_random,json=challengeRandom,proto3" json:"challenge_random,omitempty"`
	// contains filtered or unexported fields
}

func (*ChallengeRequest) Descriptor

func (*ChallengeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ChallengeRequest.ProtoReflect.Descriptor instead.

func (*ChallengeRequest) GetChallengeId

func (x *ChallengeRequest) GetChallengeId() string

func (*ChallengeRequest) GetChallengeRandom

func (x *ChallengeRequest) GetChallengeRandom() []byte

func (*ChallengeRequest) ProtoMessage

func (*ChallengeRequest) ProtoMessage()

func (*ChallengeRequest) ProtoReflect

func (x *ChallengeRequest) ProtoReflect() protoreflect.Message

func (*ChallengeRequest) Reset

func (x *ChallengeRequest) Reset()

func (*ChallengeRequest) String

func (x *ChallengeRequest) String() string

type ChallengeResponse

type ChallengeResponse struct {

	// challenge_response combines the node nonce with the kops-controller nonce.
	// The node nonce is passed in the bootstrap request.
	// The kops-controller nonce is challenge_random in the ChallengeRequest.
	// challenge_response is expected to be sha256(node-node + kops-controller-nonce)
	ChallengeResponse []byte `protobuf:"bytes,1,opt,name=challenge_response,json=challengeResponse,proto3" json:"challenge_response,omitempty"`
	// contains filtered or unexported fields
}

func (*ChallengeResponse) Descriptor

func (*ChallengeResponse) Descriptor() ([]byte, []int)

Deprecated: Use ChallengeResponse.ProtoReflect.Descriptor instead.

func (*ChallengeResponse) GetChallengeResponse

func (x *ChallengeResponse) GetChallengeResponse() []byte

func (*ChallengeResponse) ProtoMessage

func (*ChallengeResponse) ProtoMessage()

func (*ChallengeResponse) ProtoReflect

func (x *ChallengeResponse) ProtoReflect() protoreflect.Message

func (*ChallengeResponse) Reset

func (x *ChallengeResponse) Reset()

func (*ChallengeResponse) String

func (x *ChallengeResponse) String() string

type UnimplementedCallbackServiceServer

type UnimplementedCallbackServiceServer struct {
}

UnimplementedCallbackServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCallbackServiceServer) Challenge

func (UnimplementedCallbackServiceServer) Challenge(context.Context, *ChallengeRequest) (*ChallengeResponse, error)

type UnsafeCallbackServiceServer

type UnsafeCallbackServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCallbackServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CallbackServiceServer will result in compilation errors.