gds

Apr 29, 2024

Changes in this version

+ var ErrAlreadyConnected = errors.New("already connected to directory, cannot overide dialer")

+ var ErrNotConnected = errors.New("not connected to directory service")

+ type Directory interface

+ Close func() error

+ Connect func(opts ...grpc.DialOption) error

+ Detail func(ctx context.Context, in *members.DetailsRequest, opts ...grpc.CallOption) (*members.MemberDetails, error)

+ List func(ctx context.Context, in *members.ListRequest, opts ...grpc.CallOption) (*members.ListReply, error)

+ Lookup func(ctx context.Context, in *gds.LookupRequest, opts ...grpc.CallOption) (*gds.LookupReply, error)

+ Search func(ctx context.Context, in *gds.SearchRequest, opts ...grpc.CallOption) (*gds.SearchReply, error)

+ Status func(ctx context.Context, in *gds.HealthCheck, opts ...grpc.CallOption) (*gds.ServiceState, error)

+ Summary func(ctx context.Context, in *members.SummaryRequest, opts ...grpc.CallOption) (*members.SummaryReply, error)

+ type GDS struct

+ func New(conf config.TRISAConfig) *GDS

+ func (g *GDS) Close() (err error)

+ func (g *GDS) Connect(opts ...grpc.DialOption) (err error)

+ func (g *GDS) Detail(ctx context.Context, in *members.DetailsRequest, opts ...grpc.CallOption) (*members.MemberDetails, error)

+ func (g *GDS) List(ctx context.Context, in *members.ListRequest, opts ...grpc.CallOption) (*members.ListReply, error)

+ func (g *GDS) Lookup(ctx context.Context, in *gds.LookupRequest, opts ...grpc.CallOption) (*gds.LookupReply, error)

+ func (g *GDS) Search(ctx context.Context, in *gds.SearchRequest, opts ...grpc.CallOption) (*gds.SearchReply, error)

+ func (g *GDS) Status(ctx context.Context, in *gds.HealthCheck, opts ...grpc.CallOption) (*gds.ServiceState, error)

+ func (g *GDS) String() string

+ func (g *GDS) Summary(ctx context.Context, in *members.SummaryRequest, opts ...grpc.CallOption) (*members.SummaryReply, error)

+ type MockGDS struct

+ func NewMock(conf config.TRISAConfig) *MockGDS

+ func (m *MockGDS) Close() (err error)

+ func (m *MockGDS) Connect(opts ...grpc.DialOption) (err error)

+ func (m *MockGDS) GetBufnet() *bufconn.Listener

+ func (m *MockGDS) GetMock() *mock.GDS