api

Documentation

Index

• Constants
• func SchemaDetailToSchemaRecord(detail *pb.SchemaDetail) (model.SchemaRecord, error)
• func SchemaRecordToSchemaDetail(record model.SchemaRecord) pb.SchemaDetail
• type Local_SubscribeServer
• type Service
  • func (s *Service) Publish(ctx context.Context, req *pb.PublishRequest) (*pb.PublishReply, error)
  • func (s *Service) RegisterSchema(ctx context.Context, req *pb.RegisterSchemaRequest) (*pb.RegisterSchemaReply, error)
  • func (s *Service) Setup(ctx context.Context, baseThreadIdStr string)
  • func (s *Service) Subscribe(req *pb.SubscribeRequest, subscriber Local_SubscribeServer) error

Constants

const (
	DefaultBaseThreadIdStr = "bafk5ibp7tq5iel4cw7wtnrv27h6dj3zn543fgatnj5cb5qjmz3jtr7y"
	DefaultSignature       = `12D3KooWBrYBi2PCjNUH4T9pyocAApCcne6hfWZRg6LJJwzFDeq7`
)

Functions

func SchemaDetailToSchemaRecord

func SchemaDetailToSchemaRecord(detail *pb.SchemaDetail) (model.SchemaRecord, error)

func SchemaRecordToSchemaDetail

func SchemaRecordToSchemaDetail(record model.SchemaRecord) pb.SchemaDetail

Types

type Local_SubscribeServer

type Local_SubscribeServer interface {
	Send(*pb.DataRecordReply) error
}

type Service

type Service struct {
	ThreadClientStruct *threadshelper.ClientStruct
	// contains filtered or unexported fields
}

func (*Service) Publish

func (s *Service) Publish(ctx context.Context, req *pb.PublishRequest) (*pb.PublishReply, error)

func (*Service) RegisterSchema

func (s *Service) RegisterSchema(ctx context.Context, req *pb.RegisterSchemaRequest) (*pb.RegisterSchemaReply, error)

func (*Service) Setup

func (s *Service) Setup(ctx context.Context, baseThreadIdStr string)

func (*Service) Subscribe

func (s *Service) Subscribe(req *pb.SubscribeRequest, subscriber Local_SubscribeServer) error

func (s *Service) Subscribe(req *pb.SubscribeRequest, subscriber pb.API_SubscribeServer) error {