transport

Documentation

Index

• func DecodeCredential(r protobuf.Credential) (c types.Credential, err error)
• func DecodeMetdataStreamResponse(ctx context.Context, r ProtobufMetadataStream) (endpoints.MetadataStream, error)
• func EncodeCredentialRequest(r types.CredentialInput) protobuf.CredentialRequest
• func EncodeIdRequest(r endpoints.IDRequest) protobuf.IdRequest
• func EncodeSourceHostRequest(request endpoints.SourceHostRequest) *protobuf.SourceHostRequest
• func EncodeUpdateRequest(r endpoints.UpdateRequest) protobuf.UpdateRequest
• type GRPCServer
  • func NewGRPCServer(svc types.Service, logger log.Logger) GRPCServer
  • func (s GRPCServer) Create(ctx context.Context, r *protobuf.CredentialRequest) (*protobuf.Credential, error)
  • func (s GRPCServer) Delete(ctx context.Context, r *protobuf.IdRequest) (*protobuf.SuccessResponse, error)
  • func (s GRPCServer) Get(ctx context.Context, r *protobuf.IdRequest) (*protobuf.Credential, error)
  • func (s GRPCServer) GetAllMetadata(r *protobuf.SourceHostRequest, srv protobuf.Credentials_GetAllMetadataServer) (err error)
  • func (s GRPCServer) Update(ctx context.Context, r *protobuf.UpdateRequest) (*protobuf.Credential, error)
• type ProtobufMetadataStream

Functions

func DecodeCredential

func DecodeCredential(r protobuf.Credential) (c types.Credential, err error)

func DecodeMetdataStreamResponse

func DecodeMetdataStreamResponse(ctx context.Context, r ProtobufMetadataStream) (endpoints.MetadataStream, error)

func EncodeCredentialRequest

func EncodeCredentialRequest(r types.CredentialInput) protobuf.CredentialRequest

func EncodeIdRequest

func EncodeIdRequest(r endpoints.IDRequest) protobuf.IdRequest

func EncodeSourceHostRequest

func EncodeSourceHostRequest(request endpoints.SourceHostRequest) *protobuf.SourceHostRequest

func EncodeUpdateRequest

func EncodeUpdateRequest(r endpoints.UpdateRequest) protobuf.UpdateRequest

Types

type GRPCServer

type GRPCServer struct {
	// contains filtered or unexported fields
}

func NewGRPCServer

func NewGRPCServer(svc types.Service, logger log.Logger) GRPCServer

func (GRPCServer) Create

func (s GRPCServer) Create(ctx context.Context, r *protobuf.CredentialRequest) (*protobuf.Credential, error)

func (GRPCServer) Delete

func (s GRPCServer) Delete(ctx context.Context, r *protobuf.IdRequest) (*protobuf.SuccessResponse, error)

func (GRPCServer) Get

func (s GRPCServer) Get(ctx context.Context, r *protobuf.IdRequest) (*protobuf.Credential, error)

func (GRPCServer) GetAllMetadata

func (s GRPCServer) GetAllMetadata(r *protobuf.SourceHostRequest, srv protobuf.Credentials_GetAllMetadataServer) (err error)

func (GRPCServer) Update

func (s GRPCServer) Update(ctx context.Context, r *protobuf.UpdateRequest) (*protobuf.Credential, error)

type ProtobufMetadataStream

type ProtobufMetadataStream struct {
	Metadata <-chan protobuf.Metadata
	Errors   chan error
}