service

Documentation

Overview

Package service implements sentinel endpoints.

Index

• type Service
  • func New(validator sentinel.Validator, pinner sentinel.Pinner, ...) *Service
  • func (s *Service) GetHeadCID(ctx context.Context, req *sentinelpb.GetHeadCIDRequest) (*sentinelpb.GetHeadCIDResponse, error)
  • func (s *Service) GetHeadIPNS(ctx context.Context, req *sentinelpb.GetHeadIPNSRequest) (*sentinelpb.GetHeadIPNSResponse, error)
  • func (s *Service) Publish(ctx context.Context, req *sentinelpb.PublishRequest) (*sentinelpb.PublishResponse, error)

Types

type Service

type Service struct {
	sentinelpb.UnimplementedSentinelServer
	// contains filtered or unexported fields
}

Service implements sentinel GRPC server

func New

func New(validator sentinel.Validator, pinner sentinel.Pinner, commiter sentinel.Commiter, headReader thead.Reader,
	ipnsManager ipns.Manager) *Service

New initializes sentinel service

func (*Service) GetHeadCID

func (s *Service) GetHeadCID(ctx context.Context, req *sentinelpb.GetHeadCIDRequest) (*sentinelpb.GetHeadCIDResponse, error)

GetHeadCID can be used by consumers to fetch head from sentinel

func (*Service) GetHeadIPNS

func (s *Service) GetHeadIPNS(ctx context.Context, req *sentinelpb.GetHeadIPNSRequest) (*sentinelpb.GetHeadIPNSResponse, error)

GetHeadCID can be used by consumers to fetch head from sentinel

func (*Service) Publish

func (s *Service) Publish(ctx context.Context, req *sentinelpb.PublishRequest) (*sentinelpb.PublishResponse, error)

Publish is GRPC method that producers can use to add message to topic