observer

Documentation

Index

• type DocumentChangeInfoServer
  • func (s *DocumentChangeInfoServer) Equals(_ context.Context, req *pb.EqualsRequest) (*pb.EqualsResponse, error)
  • func (s *DocumentChangeInfoServer) GetChangedDocumentIds(_ context.Context, req *pb.GetChangedDocumentIdsRequest) (*pb.GetChangedDocumentIdsResponse, error)
  • func (s *DocumentChangeInfoServer) GetDatabaseName(_ context.Context, req *pb.GetDatabaseNameRequest) (*pb.GetDatabaseNameResponse, error)
  • func (s *DocumentChangeInfoServer) GetNamespace(_ context.Context, req *pb.GetNamespaceRequest) (*pb.GetNamespaceResponse, error)
  • func (s *DocumentChangeInfoServer) GetPackageName(_ context.Context, req *pb.GetPackageNameRequest) (*pb.GetPackageNameResponse, error)
  • func (s *DocumentChangeInfoServer) GetSchemaName(_ context.Context, req *pb.GetSchemaNameRequest) (*pb.GetSchemaNameResponse, error)
  • func (s *DocumentChangeInfoServer) HashCode(_ context.Context, req *pb.HashCodeRequest) (*pb.HashCodeResponse, error)
  • func (s *DocumentChangeInfoServer) NewDocumentChangeInfo(_ context.Context, req *pb.NewDocumentChangeInfoRequest) (*pb.NewDocumentChangeInfoResponse, error)
  • func (s *DocumentChangeInfoServer) ToString(_ context.Context, req *pb.ToStringRequest) (*pb.ToStringResponse, error)
• type SchemaChangeInfoServer
  • func (s *SchemaChangeInfoServer) Equals(_ context.Context, req *pb.EqualsRequest) (*pb.EqualsResponse, error)
  • func (s *SchemaChangeInfoServer) GetChangedSchemaNames(_ context.Context, req *pb.GetChangedSchemaNamesRequest) (*pb.GetChangedSchemaNamesResponse, error)
  • func (s *SchemaChangeInfoServer) GetDatabaseName(_ context.Context, req *pb.GetDatabaseNameRequest) (*pb.GetDatabaseNameResponse, error)
  • func (s *SchemaChangeInfoServer) GetPackageName(_ context.Context, req *pb.GetPackageNameRequest) (*pb.GetPackageNameResponse, error)
  • func (s *SchemaChangeInfoServer) HashCode(_ context.Context, req *pb.HashCodeRequest) (*pb.HashCodeResponse, error)
  • func (s *SchemaChangeInfoServer) NewSchemaChangeInfo(_ context.Context, req *pb.NewSchemaChangeInfoRequest) (*pb.NewSchemaChangeInfoResponse, error)
  • func (s *SchemaChangeInfoServer) ToString(_ context.Context, req *pb.ToStringRequest) (*pb.ToStringResponse, error)

Types

type DocumentChangeInfoServer

type DocumentChangeInfoServer struct {
	pb.UnimplementedDocumentChangeInfoServiceServer
	Ctx     *app.Context
	Handles *handlestore.HandleStore
}

DocumentChangeInfoServer implements pb.DocumentChangeInfoServiceServer.

func (*DocumentChangeInfoServer) Equals

func (s *DocumentChangeInfoServer) Equals(_ context.Context, req *pb.EqualsRequest) (*pb.EqualsResponse, error)

func (*DocumentChangeInfoServer) GetChangedDocumentIds

func (s *DocumentChangeInfoServer) GetChangedDocumentIds(_ context.Context, req *pb.GetChangedDocumentIdsRequest) (*pb.GetChangedDocumentIdsResponse, error)

func (*DocumentChangeInfoServer) GetDatabaseName

func (s *DocumentChangeInfoServer) GetDatabaseName(_ context.Context, req *pb.GetDatabaseNameRequest) (*pb.GetDatabaseNameResponse, error)

func (*DocumentChangeInfoServer) GetNamespace

func (s *DocumentChangeInfoServer) GetNamespace(_ context.Context, req *pb.GetNamespaceRequest) (*pb.GetNamespaceResponse, error)

func (*DocumentChangeInfoServer) GetPackageName

func (s *DocumentChangeInfoServer) GetPackageName(_ context.Context, req *pb.GetPackageNameRequest) (*pb.GetPackageNameResponse, error)

func (*DocumentChangeInfoServer) GetSchemaName

func (s *DocumentChangeInfoServer) GetSchemaName(_ context.Context, req *pb.GetSchemaNameRequest) (*pb.GetSchemaNameResponse, error)

func (*DocumentChangeInfoServer) HashCode

func (s *DocumentChangeInfoServer) HashCode(_ context.Context, req *pb.HashCodeRequest) (*pb.HashCodeResponse, error)

func (*DocumentChangeInfoServer) NewDocumentChangeInfo

func (s *DocumentChangeInfoServer) NewDocumentChangeInfo(_ context.Context, req *pb.NewDocumentChangeInfoRequest) (*pb.NewDocumentChangeInfoResponse, error)

func (*DocumentChangeInfoServer) ToString

func (s *DocumentChangeInfoServer) ToString(_ context.Context, req *pb.ToStringRequest) (*pb.ToStringResponse, error)

type SchemaChangeInfoServer

type SchemaChangeInfoServer struct {
	pb.UnimplementedSchemaChangeInfoServiceServer
	Ctx     *app.Context
	Handles *handlestore.HandleStore
}

SchemaChangeInfoServer implements pb.SchemaChangeInfoServiceServer.

func (*SchemaChangeInfoServer) Equals

func (s *SchemaChangeInfoServer) Equals(_ context.Context, req *pb.EqualsRequest) (*pb.EqualsResponse, error)

func (*SchemaChangeInfoServer) GetChangedSchemaNames

func (s *SchemaChangeInfoServer) GetChangedSchemaNames(_ context.Context, req *pb.GetChangedSchemaNamesRequest) (*pb.GetChangedSchemaNamesResponse, error)

func (*SchemaChangeInfoServer) GetDatabaseName

func (s *SchemaChangeInfoServer) GetDatabaseName(_ context.Context, req *pb.GetDatabaseNameRequest) (*pb.GetDatabaseNameResponse, error)

func (*SchemaChangeInfoServer) GetPackageName

func (s *SchemaChangeInfoServer) GetPackageName(_ context.Context, req *pb.GetPackageNameRequest) (*pb.GetPackageNameResponse, error)

func (*SchemaChangeInfoServer) HashCode

func (s *SchemaChangeInfoServer) HashCode(_ context.Context, req *pb.HashCodeRequest) (*pb.HashCodeResponse, error)

func (*SchemaChangeInfoServer) NewSchemaChangeInfo

func (s *SchemaChangeInfoServer) NewSchemaChangeInfo(_ context.Context, req *pb.NewSchemaChangeInfoRequest) (*pb.NewSchemaChangeInfoResponse, error)

func (*SchemaChangeInfoServer) ToString

func (s *SchemaChangeInfoServer) ToString(_ context.Context, req *pb.ToStringRequest) (*pb.ToStringResponse, error)