serverv1

Documentation

Index

• type MembersServer
  • func NewMembersServer(cfg *config.Config, uploads upload.Upload, metricz *metrics.Metrics, ...) *MembersServer
  • func (s *MembersServer) Append(ctx context.Context, req *connect.Request[members.AppendRequest]) (*connect.Response[members.AppendResponse], error)
  • func (s *MembersServer) Drop(ctx context.Context, req *connect.Request[members.DropRequest]) (*connect.Response[members.DropResponse], error)
  • func (s *MembersServer) List(ctx context.Context, req *connect.Request[members.ListRequest]) (*connect.Response[members.ListResponse], error)

Types

type MembersServer

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

MembersServer provides all handlers for members API.

func NewMembersServer

func NewMembersServer(
	cfg *config.Config,
	uploads upload.Upload,
	metricz *metrics.Metrics,
	repository repository.MembersRepository,
) *MembersServer

NewMembersServer initializes the member server.

func (*MembersServer) Append

func (s *MembersServer) Append(
	ctx context.Context,
	req *connect.Request[members.AppendRequest],
) (*connect.Response[members.AppendResponse], error)

Append implements the MembersServiceHandler interface.

func (*MembersServer) Drop

func (s *MembersServer) Drop(
	ctx context.Context,
	req *connect.Request[members.DropRequest],
) (*connect.Response[members.DropResponse], error)

Drop implements the MembersServiceHandler interface.

func (*MembersServer) List

func (s *MembersServer) List(
	ctx context.Context,
	req *connect.Request[members.ListRequest],
) (*connect.Response[members.ListResponse], error)

List implements the MembersServiceHandler interface.