content

Documentation

Index

• func NewStoreFromClient(client contentapi.ContentClient) content.Store
• type Service
  • func NewService(cs content.Store, publisher events.Publisher) (*Service, error)
  • func (s *Service) Abort(ctx context.Context, req *api.AbortRequest) (*empty.Empty, error)
  • func (s *Service) Delete(ctx context.Context, req *api.DeleteContentRequest) (*empty.Empty, error)
  • func (s *Service) Info(ctx context.Context, req *api.InfoRequest) (*api.InfoResponse, error)
  • func (s *Service) List(req *api.ListContentRequest, session api.Content_ListServer) error
  • func (s *Service) ListStatuses(ctx context.Context, req *api.ListStatusesRequest) (*api.ListStatusesResponse, error)
  • func (s *Service) Read(req *api.ReadContentRequest, session api.Content_ReadServer) error
  • func (s *Service) Register(server *grpc.Server) error
  • func (s *Service) Status(ctx context.Context, req *api.StatusRequest) (*api.StatusResponse, error)
  • func (s *Service) Update(ctx context.Context, req *api.UpdateRequest) (*api.UpdateResponse, error)
  • func (s *Service) Write(session api.Content_WriteServer) (err error)

Functions

func NewStoreFromClient

func NewStoreFromClient(client contentapi.ContentClient) content.Store

Types

type Service

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

func NewService

func NewService(cs content.Store, publisher events.Publisher) (*Service, error)

func (*Service) Abort

func (s *Service) Abort(ctx context.Context, req *api.AbortRequest) (*empty.Empty, error)

func (*Service) Delete

func (s *Service) Delete(ctx context.Context, req *api.DeleteContentRequest) (*empty.Empty, error)

func (*Service) Info

func (s *Service) Info(ctx context.Context, req *api.InfoRequest) (*api.InfoResponse, error)

func (*Service) List

func (s *Service) List(req *api.ListContentRequest, session api.Content_ListServer) error

func (*Service) ListStatuses

func (s *Service) ListStatuses(ctx context.Context, req *api.ListStatusesRequest) (*api.ListStatusesResponse, error)

func (*Service) Read

func (s *Service) Read(req *api.ReadContentRequest, session api.Content_ReadServer) error

func (*Service) Register

func (s *Service) Register(server *grpc.Server) error

func (*Service) Status

func (s *Service) Status(ctx context.Context, req *api.StatusRequest) (*api.StatusResponse, error)

func (*Service) Update

func (s *Service) Update(ctx context.Context, req *api.UpdateRequest) (*api.UpdateResponse, error)

func (*Service) Write

func (s *Service) Write(session api.Content_WriteServer) (err error)