databroker

package
v0.10.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 28, 2020 License: Apache-2.0 Imports: 12 Imported by: 6

Documentation

Overview

Package databroker contains databroker protobuf definitions.

Index

Constants

This section is empty.

Variables

View Source 
var File_databroker_proto protoreflect.FileDescriptor

Functions

func GetUserID 

func GetUserID(provider, providerUserID string) string

GetUserID gets the databroker user id from a provider user id.

func RegisterDataBrokerServiceServer 

func RegisterDataBrokerServiceServer(s *grpc.Server, srv DataBrokerServiceServer)

Types

type DataBrokerServiceClient 

type DataBrokerServiceClient interface {
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	GetAll(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (*GetAllResponse, error)
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (DataBrokerService_SyncClient, error)
	GetTypes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetTypesResponse, error)
	SyncTypes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (DataBrokerService_SyncTypesClient, error)
}

DataBrokerServiceClient is the client API for DataBrokerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDataBrokerServiceClient 

func NewDataBrokerServiceClient(cc grpc.ClientConnInterface) DataBrokerServiceClient

type DataBrokerServiceServer 

type DataBrokerServiceServer interface {
	Delete(context.Context, *DeleteRequest) (*empty.Empty, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	GetAll(context.Context, *GetAllRequest) (*GetAllResponse, error)
	Set(context.Context, *SetRequest) (*SetResponse, error)
	Sync(*SyncRequest, DataBrokerService_SyncServer) error
	GetTypes(context.Context, *empty.Empty) (*GetTypesResponse, error)
	SyncTypes(*empty.Empty, DataBrokerService_SyncTypesServer) error
}

DataBrokerServiceServer is the server API for DataBrokerService service.

type DataBrokerService_SyncClient 

type DataBrokerService_SyncClient interface {
	Recv() (*SyncResponse, error)
	grpc.ClientStream
}

type DataBrokerService_SyncServer 

type DataBrokerService_SyncServer interface {
	Send(*SyncResponse) error
	grpc.ServerStream
}

type DataBrokerService_SyncTypesClient 

type DataBrokerService_SyncTypesClient interface {
	Recv() (*GetTypesResponse, error)
	grpc.ClientStream
}

type DataBrokerService_SyncTypesServer 

type DataBrokerService_SyncTypesServer interface {
	Send(*GetTypesResponse) error
	grpc.ServerStream
}

type DeleteRequest 

type DeleteRequest struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Id   string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

func (*DeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetId 

func (x *DeleteRequest) GetId() string

func (*DeleteRequest) GetType 

func (x *DeleteRequest) GetType() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type GetAllRequest 

type GetAllRequest struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllRequest) Descriptor deprecated 

func (*GetAllRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetAllRequest.ProtoReflect.Descriptor instead.

func (*GetAllRequest) GetType 

func (x *GetAllRequest) GetType() string

func (*GetAllRequest) ProtoMessage 

func (*GetAllRequest) ProtoMessage()

func (*GetAllRequest) ProtoReflect 

func (x *GetAllRequest) ProtoReflect() protoreflect.Message

func (*GetAllRequest) Reset 

func (x *GetAllRequest) Reset()

func (*GetAllRequest) String 

func (x *GetAllRequest) String() string

type GetAllResponse 

type GetAllResponse struct {
	Records       []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	ServerVersion string    `protobuf:"bytes,2,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	RecordVersion string    `protobuf:"bytes,3,opt,name=record_version,json=recordVersion,proto3" json:"record_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllResponse) Descriptor deprecated 

func (*GetAllResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetAllResponse.ProtoReflect.Descriptor instead.

func (*GetAllResponse) GetRecordVersion 

func (x *GetAllResponse) GetRecordVersion() string

func (*GetAllResponse) GetRecords 

func (x *GetAllResponse) GetRecords() []*Record

func (*GetAllResponse) GetServerVersion 

func (x *GetAllResponse) GetServerVersion() string

func (*GetAllResponse) ProtoMessage 

func (*GetAllResponse) ProtoMessage()

func (*GetAllResponse) ProtoReflect 

func (x *GetAllResponse) ProtoReflect() protoreflect.Message

func (*GetAllResponse) Reset 

func (x *GetAllResponse) Reset()

func (*GetAllResponse) String 

func (x *GetAllResponse) String() string

type GetRequest 

type GetRequest struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Id   string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

func (*GetRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetId 

func (x *GetRequest) GetId() string

func (*GetRequest) GetType 

func (x *GetRequest) GetType() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

func (*GetResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetRecord 

func (x *GetResponse) GetRecord() *Record

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type GetTypesResponse 

type GetTypesResponse struct {
	Types []string `protobuf:"bytes,1,rep,name=types,proto3" json:"types,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTypesResponse) Descriptor deprecated 

func (*GetTypesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetTypesResponse.ProtoReflect.Descriptor instead.

func (*GetTypesResponse) GetTypes 

func (x *GetTypesResponse) GetTypes() []string

func (*GetTypesResponse) ProtoMessage 

func (*GetTypesResponse) ProtoMessage()

func (*GetTypesResponse) ProtoReflect 

func (x *GetTypesResponse) ProtoReflect() protoreflect.Message

func (*GetTypesResponse) Reset 

func (x *GetTypesResponse) Reset()

func (*GetTypesResponse) String 

func (x *GetTypesResponse) String() string

type Record 

type Record struct {
	Version    string               `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Type       string               `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Id         string               `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Data       *any.Any             `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	CreatedAt  *timestamp.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ModifiedAt *timestamp.Timestamp `protobuf:"bytes,6,opt,name=modified_at,json=modifiedAt,proto3" json:"modified_at,omitempty"`
	DeletedAt  *timestamp.Timestamp `protobuf:"bytes,7,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Record) Descriptor deprecated 

func (*Record) Descriptor() ([]byte, []int)

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetCreatedAt 

func (x *Record) GetCreatedAt() *timestamp.Timestamp

func (*Record) GetData 

func (x *Record) GetData() *any.Any

func (*Record) GetDeletedAt 

func (x *Record) GetDeletedAt() *timestamp.Timestamp

func (*Record) GetId 

func (x *Record) GetId() string

func (*Record) GetModifiedAt 

func (x *Record) GetModifiedAt() *timestamp.Timestamp

func (*Record) GetType 

func (x *Record) GetType() string

func (*Record) GetVersion 

func (x *Record) GetVersion() string

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

func (x *Record) ProtoReflect() protoreflect.Message

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

type ServerVersion 

type ServerVersion struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerVersion) Descriptor deprecated 

func (*ServerVersion) Descriptor() ([]byte, []int)

Deprecated: Use ServerVersion.ProtoReflect.Descriptor instead.

func (*ServerVersion) GetVersion 

func (x *ServerVersion) GetVersion() string

func (*ServerVersion) ProtoMessage 

func (*ServerVersion) ProtoMessage()

func (*ServerVersion) ProtoReflect 

func (x *ServerVersion) ProtoReflect() protoreflect.Message

func (*ServerVersion) Reset 

func (x *ServerVersion) Reset()

func (*ServerVersion) String 

func (x *ServerVersion) String() string

type SetRequest 

type SetRequest struct {
	Type string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Id   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Data *any.Any `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRequest) Descriptor deprecated 

func (*SetRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.

func (*SetRequest) GetData 

func (x *SetRequest) GetData() *any.Any

func (*SetRequest) GetId 

func (x *SetRequest) GetId() string

func (*SetRequest) GetType 

func (x *SetRequest) GetType() string

func (*SetRequest) ProtoMessage 

func (*SetRequest) ProtoMessage()

func (*SetRequest) ProtoReflect 

func (x *SetRequest) ProtoReflect() protoreflect.Message

func (*SetRequest) Reset 

func (x *SetRequest) Reset()

func (*SetRequest) String 

func (x *SetRequest) String() string

type SetResponse 

type SetResponse struct {
	Record        *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	ServerVersion string  `protobuf:"bytes,2,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	// contains filtered or unexported fields
}

func (*SetResponse) Descriptor deprecated 

func (*SetResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetResponse.ProtoReflect.Descriptor instead.

func (*SetResponse) GetRecord 

func (x *SetResponse) GetRecord() *Record

func (*SetResponse) GetServerVersion 

func (x *SetResponse) GetServerVersion() string

func (*SetResponse) ProtoMessage 

func (*SetResponse) ProtoMessage()

func (*SetResponse) ProtoReflect 

func (x *SetResponse) ProtoReflect() protoreflect.Message

func (*SetResponse) Reset 

func (x *SetResponse) Reset()

func (*SetResponse) String 

func (x *SetResponse) String() string

type SyncRequest 

type SyncRequest struct {
	ServerVersion string `protobuf:"bytes,1,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	RecordVersion string `protobuf:"bytes,2,opt,name=record_version,json=recordVersion,proto3" json:"record_version,omitempty"`
	Type          string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncRequest) Descriptor deprecated 

func (*SyncRequest) Descriptor() ([]byte, []int)

Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.

func (*SyncRequest) GetRecordVersion 

func (x *SyncRequest) GetRecordVersion() string

func (*SyncRequest) GetServerVersion 

func (x *SyncRequest) GetServerVersion() string

func (*SyncRequest) GetType 

func (x *SyncRequest) GetType() string

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoReflect 

func (x *SyncRequest) ProtoReflect() protoreflect.Message

func (*SyncRequest) Reset 

func (x *SyncRequest) Reset()

func (*SyncRequest) String 

func (x *SyncRequest) String() string

type SyncResponse 

type SyncResponse struct {
	ServerVersion string    `protobuf:"bytes,1,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	Records       []*Record `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncResponse) Descriptor deprecated 

func (*SyncResponse) Descriptor() ([]byte, []int)

Deprecated: Use SyncResponse.ProtoReflect.Descriptor instead.

func (*SyncResponse) GetRecords 

func (x *SyncResponse) GetRecords() []*Record

func (*SyncResponse) GetServerVersion 

func (x *SyncResponse) GetServerVersion() string

func (*SyncResponse) ProtoMessage 

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) ProtoReflect 

func (x *SyncResponse) ProtoReflect() protoreflect.Message

func (*SyncResponse) Reset 

func (x *SyncResponse) Reset()

func (*SyncResponse) String 

func (x *SyncResponse) String() string

type UnimplementedDataBrokerServiceServer 

type UnimplementedDataBrokerServiceServer struct {
}

UnimplementedDataBrokerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataBrokerServiceServer) Delete 

func (*UnimplementedDataBrokerServiceServer) Delete(context.Context, *DeleteRequest) (*empty.Empty, error)

func (*UnimplementedDataBrokerServiceServer) Get 

func (*UnimplementedDataBrokerServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (*UnimplementedDataBrokerServiceServer) GetAll 

func (*UnimplementedDataBrokerServiceServer) GetAll(context.Context, *GetAllRequest) (*GetAllResponse, error)

func (*UnimplementedDataBrokerServiceServer) GetTypes 

func (*UnimplementedDataBrokerServiceServer) GetTypes(context.Context, *empty.Empty) (*GetTypesResponse, error)

func (*UnimplementedDataBrokerServiceServer) Set 

func (*UnimplementedDataBrokerServiceServer) Set(context.Context, *SetRequest) (*SetResponse, error)

func (*UnimplementedDataBrokerServiceServer) Sync 

func (*UnimplementedDataBrokerServiceServer) Sync(*SyncRequest, DataBrokerService_SyncServer) error

func (*UnimplementedDataBrokerServiceServer) SyncTypes 

func (*UnimplementedDataBrokerServiceServer) SyncTypes(*empty.Empty, DataBrokerService_SyncTypesServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.