Documentation
¶
Overview ¶
Package grpc_v1 is a generated GoMock package.
Index ¶
- Variables
- func RegisterEnrollmentServer(s grpc.ServiceRegistrar, srv EnrollmentServer)
- func RegisterRouterServiceServer(s grpc.ServiceRegistrar, srv RouterServiceServer)
- type AgentChallenge
- func (*AgentChallenge) Descriptor() ([]byte, []int)deprecated
- func (x *AgentChallenge) GetChallengeRequest() *ChallengeRequest
- func (x *AgentChallenge) GetChallengeResponse() *ChallengeResponse
- func (m *AgentChallenge) GetPayload() isAgentChallenge_Payload
- func (*AgentChallenge) ProtoMessage()
- func (x *AgentChallenge) ProtoReflect() protoreflect.Message
- func (x *AgentChallenge) Reset()
- func (x *AgentChallenge) String() string
- type AgentChallenge_ChallengeRequest
- type AgentChallenge_ChallengeResponse
- type Challenge
- func (*Challenge) Descriptor() ([]byte, []int)deprecated
- func (x *Challenge) GetCredentialBlob() []byte
- func (x *Challenge) GetEncryptedSecret() []byte
- func (*Challenge) ProtoMessage()
- func (x *Challenge) ProtoReflect() protoreflect.Message
- func (x *Challenge) Reset()
- func (x *Challenge) String() string
- type ChallengeComplete
- type ChallengeError
- type ChallengeRequest
- func (*ChallengeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChallengeRequest) GetEnrollmentRequestName() string
- func (*ChallengeRequest) ProtoMessage()
- func (x *ChallengeRequest) ProtoReflect() protoreflect.Message
- func (x *ChallengeRequest) Reset()
- func (x *ChallengeRequest) String() string
- type ChallengeResponse
- type EnrollmentClient
- type EnrollmentServer
- type Enrollment_TPMChallengeClient
- type Enrollment_TPMChallengeServer
- type MockEnrollmentClient
- type MockEnrollmentClientMockRecorder
- type MockEnrollmentServer
- type MockEnrollmentServerMockRecorder
- type MockEnrollment_TPMChallengeClient
- func (m *MockEnrollment_TPMChallengeClient) CloseSend() error
- func (m *MockEnrollment_TPMChallengeClient) Context() context.Context
- func (m *MockEnrollment_TPMChallengeClient) EXPECT() *MockEnrollment_TPMChallengeClientMockRecorder
- func (m *MockEnrollment_TPMChallengeClient) Header() (metadata.MD, error)
- func (m *MockEnrollment_TPMChallengeClient) Recv() (*ServerChallenge, error)
- func (m_2 *MockEnrollment_TPMChallengeClient) RecvMsg(m any) error
- func (m *MockEnrollment_TPMChallengeClient) Send(arg0 *AgentChallenge) error
- func (m_2 *MockEnrollment_TPMChallengeClient) SendMsg(m any) error
- func (m *MockEnrollment_TPMChallengeClient) Trailer() metadata.MD
- type MockEnrollment_TPMChallengeClientMockRecorder
- func (mr *MockEnrollment_TPMChallengeClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockEnrollment_TPMChallengeClientMockRecorder) Context() *gomock.Call
- func (mr *MockEnrollment_TPMChallengeClientMockRecorder) Header() *gomock.Call
- func (mr *MockEnrollment_TPMChallengeClientMockRecorder) Recv() *gomock.Call
- func (mr *MockEnrollment_TPMChallengeClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockEnrollment_TPMChallengeClientMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockEnrollment_TPMChallengeClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockEnrollment_TPMChallengeClientMockRecorder) Trailer() *gomock.Call
- type MockEnrollment_TPMChallengeServer
- func (m *MockEnrollment_TPMChallengeServer) Context() context.Context
- func (m *MockEnrollment_TPMChallengeServer) EXPECT() *MockEnrollment_TPMChallengeServerMockRecorder
- func (m *MockEnrollment_TPMChallengeServer) Recv() (*AgentChallenge, error)
- func (m_2 *MockEnrollment_TPMChallengeServer) RecvMsg(m any) error
- func (m *MockEnrollment_TPMChallengeServer) Send(arg0 *ServerChallenge) error
- func (m *MockEnrollment_TPMChallengeServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockEnrollment_TPMChallengeServer) SendMsg(m any) error
- func (m *MockEnrollment_TPMChallengeServer) SetHeader(arg0 metadata.MD) error
- func (m *MockEnrollment_TPMChallengeServer) SetTrailer(arg0 metadata.MD)
- type MockEnrollment_TPMChallengeServerMockRecorder
- func (mr *MockEnrollment_TPMChallengeServerMockRecorder) Context() *gomock.Call
- func (mr *MockEnrollment_TPMChallengeServerMockRecorder) Recv() *gomock.Call
- func (mr *MockEnrollment_TPMChallengeServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockEnrollment_TPMChallengeServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockEnrollment_TPMChallengeServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockEnrollment_TPMChallengeServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockEnrollment_TPMChallengeServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockEnrollment_TPMChallengeServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockUnsafeEnrollmentServer
- type MockUnsafeEnrollmentServerMockRecorder
- type RouterServiceClient
- type RouterServiceServer
- type RouterService_StreamClient
- type RouterService_StreamServer
- type ServerChallenge
- func (*ServerChallenge) Descriptor() ([]byte, []int)deprecated
- func (x *ServerChallenge) GetChallenge() *Challenge
- func (x *ServerChallenge) GetError() *ChallengeError
- func (m *ServerChallenge) GetPayload() isServerChallenge_Payload
- func (x *ServerChallenge) GetSuccess() *ChallengeComplete
- func (*ServerChallenge) ProtoMessage()
- func (x *ServerChallenge) ProtoReflect() protoreflect.Message
- func (x *ServerChallenge) Reset()
- func (x *ServerChallenge) String() string
- type ServerChallenge_Challenge
- type ServerChallenge_Error
- type ServerChallenge_Success
- type StreamRequest
- func (*StreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamRequest) GetClosed() bool
- func (x *StreamRequest) GetPayload() []byte
- func (*StreamRequest) ProtoMessage()
- func (x *StreamRequest) ProtoReflect() protoreflect.Message
- func (x *StreamRequest) Reset()
- func (x *StreamRequest) String() string
- type StreamResponse
- func (*StreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamResponse) GetClosed() bool
- func (x *StreamResponse) GetPayload() []byte
- func (*StreamResponse) ProtoMessage()
- func (x *StreamResponse) ProtoReflect() protoreflect.Message
- func (x *StreamResponse) Reset()
- func (x *StreamResponse) String() string
- type UnimplementedEnrollmentServer
- type UnimplementedRouterServiceServer
- type UnsafeEnrollmentServer
- type UnsafeRouterServiceServer
Constants ¶
This section is empty.
Variables ¶
var Enrollment_ServiceDesc = grpc.ServiceDesc{ ServiceName: "flightctl.v1.Enrollment", HandlerType: (*EnrollmentServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "TPMChallenge", Handler: _Enrollment_TPMChallenge_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "enrollment.proto", }
Enrollment_ServiceDesc is the grpc.ServiceDesc for Enrollment service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_enrollment_proto protoreflect.FileDescriptor
var File_router_proto protoreflect.FileDescriptor
var RouterService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "flightctl.v1.RouterService", HandlerType: (*RouterServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Stream", Handler: _RouterService_Stream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "router.proto", }
RouterService_ServiceDesc is the grpc.ServiceDesc for RouterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterEnrollmentServer ¶ added in v0.10.0
func RegisterEnrollmentServer(s grpc.ServiceRegistrar, srv EnrollmentServer)
func RegisterRouterServiceServer ¶
func RegisterRouterServiceServer(s grpc.ServiceRegistrar, srv RouterServiceServer)
Types ¶
type AgentChallenge ¶ added in v0.10.0
type AgentChallenge struct {
// Types that are assignable to Payload:
//
// *AgentChallenge_ChallengeRequest
// *AgentChallenge_ChallengeResponse
Payload isAgentChallenge_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
AgentChallenge is a wrapper for all possible messages the agent can send.
func (*AgentChallenge) Descriptor
deprecated
added in
v0.10.0
func (*AgentChallenge) Descriptor() ([]byte, []int)
Deprecated: Use AgentChallenge.ProtoReflect.Descriptor instead.
func (*AgentChallenge) GetChallengeRequest ¶ added in v0.10.0
func (x *AgentChallenge) GetChallengeRequest() *ChallengeRequest
func (*AgentChallenge) GetChallengeResponse ¶ added in v0.10.0
func (x *AgentChallenge) GetChallengeResponse() *ChallengeResponse
func (*AgentChallenge) GetPayload ¶ added in v0.10.0
func (m *AgentChallenge) GetPayload() isAgentChallenge_Payload
func (*AgentChallenge) ProtoMessage ¶ added in v0.10.0
func (*AgentChallenge) ProtoMessage()
func (*AgentChallenge) ProtoReflect ¶ added in v0.10.0
func (x *AgentChallenge) ProtoReflect() protoreflect.Message
func (*AgentChallenge) Reset ¶ added in v0.10.0
func (x *AgentChallenge) Reset()
func (*AgentChallenge) String ¶ added in v0.10.0
func (x *AgentChallenge) String() string
type AgentChallenge_ChallengeRequest ¶ added in v0.10.0
type AgentChallenge_ChallengeRequest struct {
// The first message sent by the agent to request a challenge.
ChallengeRequest *ChallengeRequest `protobuf:"bytes,1,opt,name=challenge_request,json=challengeRequest,proto3,oneof"`
}
type AgentChallenge_ChallengeResponse ¶ added in v0.10.0
type AgentChallenge_ChallengeResponse struct {
// The agent's response containing the decrypted secret.
ChallengeResponse *ChallengeResponse `protobuf:"bytes,2,opt,name=challenge_response,json=challengeResponse,proto3,oneof"`
}
type Challenge ¶ added in v0.10.0
type Challenge struct {
// The encrypted data blob that the agent must
// pass to the TPM's ActivateCredential command.
CredentialBlob []byte `protobuf:"bytes,1,opt,name=credential_blob,json=credentialBlob,proto3" json:"credential_blob,omitempty"`
// The encrypted secret that accompanies the credential blob.
EncryptedSecret []byte `protobuf:"bytes,2,opt,name=encrypted_secret,json=encryptedSecret,proto3" json:"encrypted_secret,omitempty"`
// contains filtered or unexported fields
}
Challenge is sent by the server and contains the credential blob the agent needs to solve.
func (*Challenge) Descriptor
deprecated
added in
v0.10.0
func (*Challenge) GetCredentialBlob ¶ added in v0.10.0
func (*Challenge) GetEncryptedSecret ¶ added in v0.10.0
func (*Challenge) ProtoMessage ¶ added in v0.10.0
func (*Challenge) ProtoMessage()
func (*Challenge) ProtoReflect ¶ added in v0.10.0
func (x *Challenge) ProtoReflect() protoreflect.Message
type ChallengeComplete ¶ added in v0.10.0
type ChallengeComplete struct {
// A human-readable success message.
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
ChallengeComplete signals a successful end to the challenge.
func (*ChallengeComplete) Descriptor
deprecated
added in
v0.10.0
func (*ChallengeComplete) Descriptor() ([]byte, []int)
Deprecated: Use ChallengeComplete.ProtoReflect.Descriptor instead.
func (*ChallengeComplete) GetMessage ¶ added in v0.10.0
func (x *ChallengeComplete) GetMessage() string
func (*ChallengeComplete) ProtoMessage ¶ added in v0.10.0
func (*ChallengeComplete) ProtoMessage()
func (*ChallengeComplete) ProtoReflect ¶ added in v0.10.0
func (x *ChallengeComplete) ProtoReflect() protoreflect.Message
func (*ChallengeComplete) Reset ¶ added in v0.10.0
func (x *ChallengeComplete) Reset()
func (*ChallengeComplete) String ¶ added in v0.10.0
func (x *ChallengeComplete) String() string
type ChallengeError ¶ added in v0.10.0
type ChallengeError struct {
// A human-readable error message.
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
ChallengeError signals a failure and terminates the challenge.
func (*ChallengeError) Descriptor
deprecated
added in
v0.10.0
func (*ChallengeError) Descriptor() ([]byte, []int)
Deprecated: Use ChallengeError.ProtoReflect.Descriptor instead.
func (*ChallengeError) GetMessage ¶ added in v0.10.0
func (x *ChallengeError) GetMessage() string
func (*ChallengeError) ProtoMessage ¶ added in v0.10.0
func (*ChallengeError) ProtoMessage()
func (*ChallengeError) ProtoReflect ¶ added in v0.10.0
func (x *ChallengeError) ProtoReflect() protoreflect.Message
func (*ChallengeError) Reset ¶ added in v0.10.0
func (x *ChallengeError) Reset()
func (*ChallengeError) String ¶ added in v0.10.0
func (x *ChallengeError) String() string
type ChallengeRequest ¶ added in v0.10.0
type ChallengeRequest struct {
// The name of the EnrollmentRequest resource created via the REST API.
EnrollmentRequestName string `` /* 126-byte string literal not displayed */
// contains filtered or unexported fields
}
ChallengeRequest is sent by the client to initiate the challenge for a specific EnrollmentRequest.
func (*ChallengeRequest) Descriptor
deprecated
added in
v0.10.0
func (*ChallengeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChallengeRequest.ProtoReflect.Descriptor instead.
func (*ChallengeRequest) GetEnrollmentRequestName ¶ added in v0.10.0
func (x *ChallengeRequest) GetEnrollmentRequestName() string
func (*ChallengeRequest) ProtoMessage ¶ added in v0.10.0
func (*ChallengeRequest) ProtoMessage()
func (*ChallengeRequest) ProtoReflect ¶ added in v0.10.0
func (x *ChallengeRequest) ProtoReflect() protoreflect.Message
func (*ChallengeRequest) Reset ¶ added in v0.10.0
func (x *ChallengeRequest) Reset()
func (*ChallengeRequest) String ¶ added in v0.10.0
func (x *ChallengeRequest) String() string
type ChallengeResponse ¶ added in v0.10.0
type ChallengeResponse struct {
// The raw bytes of the secret decrypted by the TPM.
Secret []byte `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
// contains filtered or unexported fields
}
ChallengeResponse contains the agent's decrypted secret.
func (*ChallengeResponse) Descriptor
deprecated
added in
v0.10.0
func (*ChallengeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChallengeResponse.ProtoReflect.Descriptor instead.
func (*ChallengeResponse) GetSecret ¶ added in v0.10.0
func (x *ChallengeResponse) GetSecret() []byte
func (*ChallengeResponse) ProtoMessage ¶ added in v0.10.0
func (*ChallengeResponse) ProtoMessage()
func (*ChallengeResponse) ProtoReflect ¶ added in v0.10.0
func (x *ChallengeResponse) ProtoReflect() protoreflect.Message
func (*ChallengeResponse) Reset ¶ added in v0.10.0
func (x *ChallengeResponse) Reset()
func (*ChallengeResponse) String ¶ added in v0.10.0
func (x *ChallengeResponse) String() string
type EnrollmentClient ¶ added in v0.10.0
type EnrollmentClient interface {
// TPMChallenge establishes a bidirectional stream to conduct the TPM challenge-response.
TPMChallenge(ctx context.Context, opts ...grpc.CallOption) (Enrollment_TPMChallengeClient, error)
}
EnrollmentClient is the client API for Enrollment 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 NewEnrollmentClient ¶ added in v0.10.0
func NewEnrollmentClient(cc grpc.ClientConnInterface) EnrollmentClient
type EnrollmentServer ¶ added in v0.10.0
type EnrollmentServer interface {
// TPMChallenge establishes a bidirectional stream to conduct the TPM challenge-response.
TPMChallenge(Enrollment_TPMChallengeServer) error
// contains filtered or unexported methods
}
EnrollmentServer is the server API for Enrollment service. All implementations must embed UnimplementedEnrollmentServer for forward compatibility
type Enrollment_TPMChallengeClient ¶ added in v0.10.0
type Enrollment_TPMChallengeClient interface {
Send(*AgentChallenge) error
Recv() (*ServerChallenge, error)
grpc.ClientStream
}
type Enrollment_TPMChallengeServer ¶ added in v0.10.0
type Enrollment_TPMChallengeServer interface {
Send(*ServerChallenge) error
Recv() (*AgentChallenge, error)
grpc.ServerStream
}
type MockEnrollmentClient ¶ added in v0.10.0
type MockEnrollmentClient struct {
// contains filtered or unexported fields
}
MockEnrollmentClient is a mock of EnrollmentClient interface.
func NewMockEnrollmentClient ¶ added in v0.10.0
func NewMockEnrollmentClient(ctrl *gomock.Controller) *MockEnrollmentClient
NewMockEnrollmentClient creates a new mock instance.
func (*MockEnrollmentClient) EXPECT ¶ added in v0.10.0
func (m *MockEnrollmentClient) EXPECT() *MockEnrollmentClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEnrollmentClient) TPMChallenge ¶ added in v0.10.0
func (m *MockEnrollmentClient) TPMChallenge(ctx context.Context, opts ...grpc.CallOption) (Enrollment_TPMChallengeClient, error)
TPMChallenge mocks base method.
type MockEnrollmentClientMockRecorder ¶ added in v0.10.0
type MockEnrollmentClientMockRecorder struct {
// contains filtered or unexported fields
}
MockEnrollmentClientMockRecorder is the mock recorder for MockEnrollmentClient.
func (*MockEnrollmentClientMockRecorder) TPMChallenge ¶ added in v0.10.0
func (mr *MockEnrollmentClientMockRecorder) TPMChallenge(ctx any, opts ...any) *gomock.Call
TPMChallenge indicates an expected call of TPMChallenge.
type MockEnrollmentServer ¶ added in v0.10.0
type MockEnrollmentServer struct {
// contains filtered or unexported fields
}
MockEnrollmentServer is a mock of EnrollmentServer interface.
func NewMockEnrollmentServer ¶ added in v0.10.0
func NewMockEnrollmentServer(ctrl *gomock.Controller) *MockEnrollmentServer
NewMockEnrollmentServer creates a new mock instance.
func (*MockEnrollmentServer) EXPECT ¶ added in v0.10.0
func (m *MockEnrollmentServer) EXPECT() *MockEnrollmentServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEnrollmentServer) TPMChallenge ¶ added in v0.10.0
func (m *MockEnrollmentServer) TPMChallenge(arg0 Enrollment_TPMChallengeServer) error
TPMChallenge mocks base method.
type MockEnrollmentServerMockRecorder ¶ added in v0.10.0
type MockEnrollmentServerMockRecorder struct {
// contains filtered or unexported fields
}
MockEnrollmentServerMockRecorder is the mock recorder for MockEnrollmentServer.
func (*MockEnrollmentServerMockRecorder) TPMChallenge ¶ added in v0.10.0
func (mr *MockEnrollmentServerMockRecorder) TPMChallenge(arg0 any) *gomock.Call
TPMChallenge indicates an expected call of TPMChallenge.
type MockEnrollment_TPMChallengeClient ¶ added in v0.10.0
type MockEnrollment_TPMChallengeClient struct {
// contains filtered or unexported fields
}
MockEnrollment_TPMChallengeClient is a mock of Enrollment_TPMChallengeClient interface.
func NewMockEnrollment_TPMChallengeClient ¶ added in v0.10.0
func NewMockEnrollment_TPMChallengeClient(ctrl *gomock.Controller) *MockEnrollment_TPMChallengeClient
NewMockEnrollment_TPMChallengeClient creates a new mock instance.
func (*MockEnrollment_TPMChallengeClient) CloseSend ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeClient) CloseSend() error
CloseSend mocks base method.
func (*MockEnrollment_TPMChallengeClient) Context ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeClient) Context() context.Context
Context mocks base method.
func (*MockEnrollment_TPMChallengeClient) EXPECT ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeClient) EXPECT() *MockEnrollment_TPMChallengeClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEnrollment_TPMChallengeClient) Header ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockEnrollment_TPMChallengeClient) Recv ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeClient) Recv() (*ServerChallenge, error)
Recv mocks base method.
func (*MockEnrollment_TPMChallengeClient) RecvMsg ¶ added in v0.10.0
func (m_2 *MockEnrollment_TPMChallengeClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockEnrollment_TPMChallengeClient) Send ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeClient) Send(arg0 *AgentChallenge) error
Send mocks base method.
func (*MockEnrollment_TPMChallengeClient) SendMsg ¶ added in v0.10.0
func (m_2 *MockEnrollment_TPMChallengeClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockEnrollment_TPMChallengeClient) Trailer ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeClient) Trailer() metadata.MD
Trailer mocks base method.
type MockEnrollment_TPMChallengeClientMockRecorder ¶ added in v0.10.0
type MockEnrollment_TPMChallengeClientMockRecorder struct {
// contains filtered or unexported fields
}
MockEnrollment_TPMChallengeClientMockRecorder is the mock recorder for MockEnrollment_TPMChallengeClient.
func (*MockEnrollment_TPMChallengeClientMockRecorder) CloseSend ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockEnrollment_TPMChallengeClientMockRecorder) Context ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockEnrollment_TPMChallengeClientMockRecorder) Header ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockEnrollment_TPMChallengeClientMockRecorder) Recv ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockEnrollment_TPMChallengeClientMockRecorder) RecvMsg ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockEnrollment_TPMChallengeClientMockRecorder) Send ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeClientMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockEnrollment_TPMChallengeClientMockRecorder) SendMsg ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockEnrollment_TPMChallengeClientMockRecorder) Trailer ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockEnrollment_TPMChallengeServer ¶ added in v0.10.0
type MockEnrollment_TPMChallengeServer struct {
// contains filtered or unexported fields
}
MockEnrollment_TPMChallengeServer is a mock of Enrollment_TPMChallengeServer interface.
func NewMockEnrollment_TPMChallengeServer ¶ added in v0.10.0
func NewMockEnrollment_TPMChallengeServer(ctrl *gomock.Controller) *MockEnrollment_TPMChallengeServer
NewMockEnrollment_TPMChallengeServer creates a new mock instance.
func (*MockEnrollment_TPMChallengeServer) Context ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeServer) Context() context.Context
Context mocks base method.
func (*MockEnrollment_TPMChallengeServer) EXPECT ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeServer) EXPECT() *MockEnrollment_TPMChallengeServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEnrollment_TPMChallengeServer) Recv ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeServer) Recv() (*AgentChallenge, error)
Recv mocks base method.
func (*MockEnrollment_TPMChallengeServer) RecvMsg ¶ added in v0.10.0
func (m_2 *MockEnrollment_TPMChallengeServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockEnrollment_TPMChallengeServer) Send ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeServer) Send(arg0 *ServerChallenge) error
Send mocks base method.
func (*MockEnrollment_TPMChallengeServer) SendHeader ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockEnrollment_TPMChallengeServer) SendMsg ¶ added in v0.10.0
func (m_2 *MockEnrollment_TPMChallengeServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockEnrollment_TPMChallengeServer) SetHeader ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockEnrollment_TPMChallengeServer) SetTrailer ¶ added in v0.10.0
func (m *MockEnrollment_TPMChallengeServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockEnrollment_TPMChallengeServerMockRecorder ¶ added in v0.10.0
type MockEnrollment_TPMChallengeServerMockRecorder struct {
// contains filtered or unexported fields
}
MockEnrollment_TPMChallengeServerMockRecorder is the mock recorder for MockEnrollment_TPMChallengeServer.
func (*MockEnrollment_TPMChallengeServerMockRecorder) Context ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockEnrollment_TPMChallengeServerMockRecorder) Recv ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockEnrollment_TPMChallengeServerMockRecorder) RecvMsg ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockEnrollment_TPMChallengeServerMockRecorder) Send ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockEnrollment_TPMChallengeServerMockRecorder) SendHeader ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockEnrollment_TPMChallengeServerMockRecorder) SendMsg ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockEnrollment_TPMChallengeServerMockRecorder) SetHeader ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockEnrollment_TPMChallengeServerMockRecorder) SetTrailer ¶ added in v0.10.0
func (mr *MockEnrollment_TPMChallengeServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockUnsafeEnrollmentServer ¶ added in v0.10.0
type MockUnsafeEnrollmentServer struct {
// contains filtered or unexported fields
}
MockUnsafeEnrollmentServer is a mock of UnsafeEnrollmentServer interface.
func NewMockUnsafeEnrollmentServer ¶ added in v0.10.0
func NewMockUnsafeEnrollmentServer(ctrl *gomock.Controller) *MockUnsafeEnrollmentServer
NewMockUnsafeEnrollmentServer creates a new mock instance.
func (*MockUnsafeEnrollmentServer) EXPECT ¶ added in v0.10.0
func (m *MockUnsafeEnrollmentServer) EXPECT() *MockUnsafeEnrollmentServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockUnsafeEnrollmentServerMockRecorder ¶ added in v0.10.0
type MockUnsafeEnrollmentServerMockRecorder struct {
// contains filtered or unexported fields
}
MockUnsafeEnrollmentServerMockRecorder is the mock recorder for MockUnsafeEnrollmentServer.
type RouterServiceClient ¶
type RouterServiceClient interface {
// Stream connects caller to another caller of the same stream
// in the call context we expect:
// - the stream ID
Stream(ctx context.Context, opts ...grpc.CallOption) (RouterService_StreamClient, error)
}
RouterServiceClient is the client API for RouterService 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 NewRouterServiceClient ¶
func NewRouterServiceClient(cc grpc.ClientConnInterface) RouterServiceClient
type RouterServiceServer ¶
type RouterServiceServer interface {
// Stream connects caller to another caller of the same stream
// in the call context we expect:
// - the stream ID
Stream(RouterService_StreamServer) error
// contains filtered or unexported methods
}
RouterServiceServer is the server API for RouterService service. All implementations must embed UnimplementedRouterServiceServer for forward compatibility
type RouterService_StreamClient ¶
type RouterService_StreamClient interface {
Send(*StreamRequest) error
Recv() (*StreamResponse, error)
grpc.ClientStream
}
type RouterService_StreamServer ¶
type RouterService_StreamServer interface {
Send(*StreamResponse) error
Recv() (*StreamRequest, error)
grpc.ServerStream
}
type ServerChallenge ¶ added in v0.10.0
type ServerChallenge struct {
// Types that are assignable to Payload:
//
// *ServerChallenge_Challenge
// *ServerChallenge_Success
// *ServerChallenge_Error
Payload isServerChallenge_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
ServerChallenge is a wrapper for all possible messages the service can send.
func (*ServerChallenge) Descriptor
deprecated
added in
v0.10.0
func (*ServerChallenge) Descriptor() ([]byte, []int)
Deprecated: Use ServerChallenge.ProtoReflect.Descriptor instead.
func (*ServerChallenge) GetChallenge ¶ added in v0.10.0
func (x *ServerChallenge) GetChallenge() *Challenge
func (*ServerChallenge) GetError ¶ added in v0.10.0
func (x *ServerChallenge) GetError() *ChallengeError
func (*ServerChallenge) GetPayload ¶ added in v0.10.0
func (m *ServerChallenge) GetPayload() isServerChallenge_Payload
func (*ServerChallenge) GetSuccess ¶ added in v0.10.0
func (x *ServerChallenge) GetSuccess() *ChallengeComplete
func (*ServerChallenge) ProtoMessage ¶ added in v0.10.0
func (*ServerChallenge) ProtoMessage()
func (*ServerChallenge) ProtoReflect ¶ added in v0.10.0
func (x *ServerChallenge) ProtoReflect() protoreflect.Message
func (*ServerChallenge) Reset ¶ added in v0.10.0
func (x *ServerChallenge) Reset()
func (*ServerChallenge) String ¶ added in v0.10.0
func (x *ServerChallenge) String() string
type ServerChallenge_Challenge ¶ added in v0.10.0
type ServerChallenge_Challenge struct {
// The service's challenge containing the credential blob.
Challenge *Challenge `protobuf:"bytes,1,opt,name=challenge,proto3,oneof"`
}
type ServerChallenge_Error ¶ added in v0.10.0
type ServerChallenge_Error struct {
// A message indicating a failure at some point in the challenge.
Error *ChallengeError `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}
type ServerChallenge_Success ¶ added in v0.10.0
type ServerChallenge_Success struct {
// A message indicating the entire challenge was successful.
Success *ChallengeComplete `protobuf:"bytes,2,opt,name=success,proto3,oneof"`
}
type StreamRequest ¶
type StreamRequest struct {
Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
Closed bool `protobuf:"varint,2,opt,name=closed,proto3" json:"closed,omitempty"`
// contains filtered or unexported fields
}
func (*StreamRequest) Descriptor
deprecated
func (*StreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.
func (*StreamRequest) GetClosed ¶
func (x *StreamRequest) GetClosed() bool
func (*StreamRequest) GetPayload ¶
func (x *StreamRequest) GetPayload() []byte
func (*StreamRequest) ProtoMessage ¶
func (*StreamRequest) ProtoMessage()
func (*StreamRequest) ProtoReflect ¶
func (x *StreamRequest) ProtoReflect() protoreflect.Message
func (*StreamRequest) Reset ¶
func (x *StreamRequest) Reset()
func (*StreamRequest) String ¶
func (x *StreamRequest) String() string
type StreamResponse ¶
type StreamResponse struct {
Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
Closed bool `protobuf:"varint,2,opt,name=closed,proto3" json:"closed,omitempty"`
// contains filtered or unexported fields
}
func (*StreamResponse) Descriptor
deprecated
func (*StreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.
func (*StreamResponse) GetClosed ¶
func (x *StreamResponse) GetClosed() bool
func (*StreamResponse) GetPayload ¶
func (x *StreamResponse) GetPayload() []byte
func (*StreamResponse) ProtoMessage ¶
func (*StreamResponse) ProtoMessage()
func (*StreamResponse) ProtoReflect ¶
func (x *StreamResponse) ProtoReflect() protoreflect.Message
func (*StreamResponse) Reset ¶
func (x *StreamResponse) Reset()
func (*StreamResponse) String ¶
func (x *StreamResponse) String() string
type UnimplementedEnrollmentServer ¶ added in v0.10.0
type UnimplementedEnrollmentServer struct {
}
UnimplementedEnrollmentServer must be embedded to have forward compatible implementations.
func (UnimplementedEnrollmentServer) TPMChallenge ¶ added in v0.10.0
func (UnimplementedEnrollmentServer) TPMChallenge(Enrollment_TPMChallengeServer) error
type UnimplementedRouterServiceServer ¶
type UnimplementedRouterServiceServer struct {
}
UnimplementedRouterServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedRouterServiceServer) Stream ¶
func (UnimplementedRouterServiceServer) Stream(RouterService_StreamServer) error
type UnsafeEnrollmentServer ¶ added in v0.10.0
type UnsafeEnrollmentServer interface {
// contains filtered or unexported methods
}
UnsafeEnrollmentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EnrollmentServer will result in compilation errors.
type UnsafeRouterServiceServer ¶
type UnsafeRouterServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRouterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RouterServiceServer will result in compilation errors.