observer

Documentation

Index

• type CallbackClient
  • func NewCallbackClient(cc grpc.ClientConnInterface) *CallbackClient
  • func (c *CallbackClient) OnDocumentChanged(ctx context.Context, arg0 int64) error
  • func (c *CallbackClient) OnSchemaChanged(ctx context.Context, arg0 int64) error
• type DocumentChangeInfoClient
  • func NewDocumentChangeInfoClient(cc grpc.ClientConnInterface) *DocumentChangeInfoClient
  • func (c *DocumentChangeInfoClient) Equals(ctx context.Context, handle int64, arg0 int64) (bool, error)
  • func (c *DocumentChangeInfoClient) GetChangedDocumentIds(ctx context.Context, handle int64) (int64, error)
  • func (c *DocumentChangeInfoClient) GetDatabaseName(ctx context.Context, handle int64) (string, error)
  • func (c *DocumentChangeInfoClient) GetNamespace(ctx context.Context, handle int64) (string, error)
  • func (c *DocumentChangeInfoClient) GetPackageName(ctx context.Context, handle int64) (string, error)
  • func (c *DocumentChangeInfoClient) GetSchemaName(ctx context.Context, handle int64) (string, error)
  • func (c *DocumentChangeInfoClient) HashCode(ctx context.Context, handle int64) (int32, error)
  • func (c *DocumentChangeInfoClient) ToString(ctx context.Context, handle int64) (string, error)
• type SchemaChangeInfoClient
  • func NewSchemaChangeInfoClient(cc grpc.ClientConnInterface) *SchemaChangeInfoClient
  • func (c *SchemaChangeInfoClient) Equals(ctx context.Context, handle int64, arg0 int64) (bool, error)
  • func (c *SchemaChangeInfoClient) GetChangedSchemaNames(ctx context.Context, handle int64) (int64, error)
  • func (c *SchemaChangeInfoClient) GetDatabaseName(ctx context.Context, handle int64) (string, error)
  • func (c *SchemaChangeInfoClient) GetPackageName(ctx context.Context, handle int64) (string, error)
  • func (c *SchemaChangeInfoClient) HashCode(ctx context.Context, handle int64) (int32, error)
  • func (c *SchemaChangeInfoClient) ToString(ctx context.Context, handle int64) (string, error)
• type SpecBuilderClient
  • func NewSpecBuilderClient(cc grpc.ClientConnInterface) *SpecBuilderClient
  • func (c *SpecBuilderClient) AddFilterSchemas(ctx context.Context, arg0 int64) (int64, error)
  • func (c *SpecBuilderClient) Build(ctx context.Context) (int64, error)
• type SpecClient
  • func NewSpecClient(cc grpc.ClientConnInterface) *SpecClient
  • func (c *SpecClient) DescribeContents(ctx context.Context) (int32, error)
  • func (c *SpecClient) GetFilterSchemas(ctx context.Context) (int64, error)
  • func (c *SpecClient) WriteToParcel(ctx context.Context, arg0 int64, arg1 int32) error

Types

type CallbackClient

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

CallbackClient wraps the gRPC CallbackService client.

func NewCallbackClient

func NewCallbackClient(cc grpc.ClientConnInterface) *CallbackClient

NewCallbackClient creates a new Callback client.

func (*CallbackClient) OnDocumentChanged

func (c *CallbackClient) OnDocumentChanged(ctx context.Context, arg0 int64) error

OnDocumentChanged calls the OnDocumentChanged RPC.

func (*CallbackClient) OnSchemaChanged

func (c *CallbackClient) OnSchemaChanged(ctx context.Context, arg0 int64) error

OnSchemaChanged calls the OnSchemaChanged RPC.

type DocumentChangeInfoClient

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

DocumentChangeInfoClient wraps the gRPC DocumentChangeInfoService client.

func NewDocumentChangeInfoClient

func NewDocumentChangeInfoClient(cc grpc.ClientConnInterface) *DocumentChangeInfoClient

NewDocumentChangeInfoClient creates a new DocumentChangeInfo client.

func (*DocumentChangeInfoClient) Equals

func (c *DocumentChangeInfoClient) Equals(ctx context.Context, handle int64, arg0 int64) (bool, error)

Equals calls the Equals RPC.

func (*DocumentChangeInfoClient) GetChangedDocumentIds

func (c *DocumentChangeInfoClient) GetChangedDocumentIds(ctx context.Context, handle int64) (int64, error)

GetChangedDocumentIds calls the GetChangedDocumentIds RPC.

func (*DocumentChangeInfoClient) GetDatabaseName

func (c *DocumentChangeInfoClient) GetDatabaseName(ctx context.Context, handle int64) (string, error)

GetDatabaseName calls the GetDatabaseName RPC.

func (*DocumentChangeInfoClient) GetNamespace

func (c *DocumentChangeInfoClient) GetNamespace(ctx context.Context, handle int64) (string, error)

GetNamespace calls the GetNamespace RPC.

func (*DocumentChangeInfoClient) GetPackageName

func (c *DocumentChangeInfoClient) GetPackageName(ctx context.Context, handle int64) (string, error)

GetPackageName calls the GetPackageName RPC.

func (*DocumentChangeInfoClient) GetSchemaName

func (c *DocumentChangeInfoClient) GetSchemaName(ctx context.Context, handle int64) (string, error)

GetSchemaName calls the GetSchemaName RPC.

func (*DocumentChangeInfoClient) HashCode

func (c *DocumentChangeInfoClient) HashCode(ctx context.Context, handle int64) (int32, error)

HashCode calls the HashCode RPC.

func (*DocumentChangeInfoClient) ToString

func (c *DocumentChangeInfoClient) ToString(ctx context.Context, handle int64) (string, error)

ToString calls the ToString RPC.

type SchemaChangeInfoClient

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

SchemaChangeInfoClient wraps the gRPC SchemaChangeInfoService client.

func NewSchemaChangeInfoClient

func NewSchemaChangeInfoClient(cc grpc.ClientConnInterface) *SchemaChangeInfoClient

NewSchemaChangeInfoClient creates a new SchemaChangeInfo client.

func (*SchemaChangeInfoClient) Equals

func (c *SchemaChangeInfoClient) Equals(ctx context.Context, handle int64, arg0 int64) (bool, error)

Equals calls the Equals RPC.

func (*SchemaChangeInfoClient) GetChangedSchemaNames

func (c *SchemaChangeInfoClient) GetChangedSchemaNames(ctx context.Context, handle int64) (int64, error)

GetChangedSchemaNames calls the GetChangedSchemaNames RPC.

func (*SchemaChangeInfoClient) GetDatabaseName

func (c *SchemaChangeInfoClient) GetDatabaseName(ctx context.Context, handle int64) (string, error)

GetDatabaseName calls the GetDatabaseName RPC.

func (*SchemaChangeInfoClient) GetPackageName

func (c *SchemaChangeInfoClient) GetPackageName(ctx context.Context, handle int64) (string, error)

GetPackageName calls the GetPackageName RPC.

func (*SchemaChangeInfoClient) HashCode

func (c *SchemaChangeInfoClient) HashCode(ctx context.Context, handle int64) (int32, error)

HashCode calls the HashCode RPC.

func (*SchemaChangeInfoClient) ToString

func (c *SchemaChangeInfoClient) ToString(ctx context.Context, handle int64) (string, error)

ToString calls the ToString RPC.

type SpecBuilderClient

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

SpecBuilderClient wraps the gRPC SpecBuilderService client.

func NewSpecBuilderClient

func NewSpecBuilderClient(cc grpc.ClientConnInterface) *SpecBuilderClient

NewSpecBuilderClient creates a new SpecBuilder client.

func (*SpecBuilderClient) AddFilterSchemas

func (c *SpecBuilderClient) AddFilterSchemas(ctx context.Context, arg0 int64) (int64, error)

AddFilterSchemas calls the AddFilterSchemas RPC.

func (*SpecBuilderClient) Build

func (c *SpecBuilderClient) Build(ctx context.Context) (int64, error)

Build calls the Build RPC.

type SpecClient

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

SpecClient wraps the gRPC SpecService client.

func NewSpecClient

func NewSpecClient(cc grpc.ClientConnInterface) *SpecClient

NewSpecClient creates a new Spec client.

func (*SpecClient) DescribeContents

func (c *SpecClient) DescribeContents(ctx context.Context) (int32, error)

DescribeContents calls the DescribeContents RPC.

func (*SpecClient) GetFilterSchemas

func (c *SpecClient) GetFilterSchemas(ctx context.Context) (int64, error)

GetFilterSchemas calls the GetFilterSchemas RPC.

func (*SpecClient) WriteToParcel

func (c *SpecClient) WriteToParcel(ctx context.Context, arg0 int64, arg1 int32) error

WriteToParcel calls the WriteToParcel RPC.