static

Documentation

Index

• type Grpc
  • func NewStaticGrpc(staticUC usecase.StaticUseCase) *Grpc
  • func (service *Grpc) GetStatic(_ context.Context, static *staticProto.Static) (*staticProto.Static, error)
  • func (service *Grpc) GetStaticFile(static *staticProto.Static, ...) error
  • func (service *Grpc) Ping(context.Context, *staticProto.Nothing) (*staticProto.Nothing, error)
  • func (service *Grpc) UploadStatic(stream staticProto.StaticService_UploadStaticServer) error
• type StaticGrpcClient
  • func NewStaticGrpcClient(connectAddr string, timeout time.Duration) (*StaticGrpcClient, error)
  • func (gate *StaticGrpcClient) GetStatic(staticID uuid.UUID) (string, error)
  • func (gate *StaticGrpcClient) GetStaticFile(staticURI string) (io.ReadSeeker, error)
  • func (gate *StaticGrpcClient) UploadStatic(reader io.ReadSeeker) (uuid.UUID, error)

Types

type Grpc

type Grpc struct {
	staticProto.UnimplementedStaticServiceServer
	// contains filtered or unexported fields
}

func NewStaticGrpc

func NewStaticGrpc(staticUC usecase.StaticUseCase) *Grpc

func (*Grpc) GetStatic

func (service *Grpc) GetStatic(_ context.Context, static *staticProto.Static) (*staticProto.Static, error)

func (*Grpc) GetStaticFile

func (service *Grpc) GetStaticFile(
	static *staticProto.Static,
	stream staticProto.StaticService_GetStaticFileServer,
) error

func (*Grpc) Ping

func (service *Grpc) Ping(context.Context, *staticProto.Nothing) (*staticProto.Nothing, error)

func (*Grpc) UploadStatic

func (service *Grpc) UploadStatic(stream staticProto.StaticService_UploadStaticServer) error

type StaticGrpcClient

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

func NewStaticGrpcClient

func NewStaticGrpcClient(connectAddr string, timeout time.Duration) (*StaticGrpcClient, error)

func (*StaticGrpcClient) GetStatic

func (gate *StaticGrpcClient) GetStatic(staticID uuid.UUID) (string, error)

func (*StaticGrpcClient) GetStaticFile

func (gate *StaticGrpcClient) GetStaticFile(staticURI string) (io.ReadSeeker, error)

func (*StaticGrpcClient) UploadStatic

func (gate *StaticGrpcClient) UploadStatic(reader io.ReadSeeker) (uuid.UUID, error)