gravity_api_dsa

package
v0.2.13 Latest Latest
Warning

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

 Go to latest Published: May 19, 2021 License: MIT Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDataSourceAdapterServer 

func RegisterDataSourceAdapterServer(s *grpc.Server, srv DataSourceAdapterServer)

Types

type BatchPublishReply 

type BatchPublishReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	SuccessCount         int32    `protobuf:"varint,2,opt,name=successCount,proto3" json:"successCount,omitempty"`
	Reason               string   `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchPublishReply) Descriptor 

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

func (*BatchPublishReply) GetReason 

func (m *BatchPublishReply) GetReason() string

func (*BatchPublishReply) GetSuccess 

func (m *BatchPublishReply) GetSuccess() bool

func (*BatchPublishReply) GetSuccessCount 

func (m *BatchPublishReply) GetSuccessCount() int32

func (*BatchPublishReply) ProtoMessage 

func (*BatchPublishReply) ProtoMessage()

func (*BatchPublishReply) Reset 

func (m *BatchPublishReply) Reset()

func (*BatchPublishReply) String 

func (m *BatchPublishReply) String() string

func (*BatchPublishReply) XXX_DiscardUnknown 

func (m *BatchPublishReply) XXX_DiscardUnknown()

func (*BatchPublishReply) XXX_Marshal 

func (m *BatchPublishReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchPublishReply) XXX_Merge 

func (m *BatchPublishReply) XXX_Merge(src proto.Message)

func (*BatchPublishReply) XXX_Size 

func (m *BatchPublishReply) XXX_Size() int

func (*BatchPublishReply) XXX_Unmarshal 

func (m *BatchPublishReply) XXX_Unmarshal(b []byte) error

type BatchPublishRequest 

type BatchPublishRequest struct {
	Requests             []*PublishRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*BatchPublishRequest) Descriptor 

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

func (*BatchPublishRequest) GetRequests 

func (m *BatchPublishRequest) GetRequests() []*PublishRequest

func (*BatchPublishRequest) ProtoMessage 

func (*BatchPublishRequest) ProtoMessage()

func (*BatchPublishRequest) Reset 

func (m *BatchPublishRequest) Reset()

func (*BatchPublishRequest) String 

func (m *BatchPublishRequest) String() string

func (*BatchPublishRequest) XXX_DiscardUnknown 

func (m *BatchPublishRequest) XXX_DiscardUnknown()

func (*BatchPublishRequest) XXX_Marshal 

func (m *BatchPublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchPublishRequest) XXX_Merge 

func (m *BatchPublishRequest) XXX_Merge(src proto.Message)

func (*BatchPublishRequest) XXX_Size 

func (m *BatchPublishRequest) XXX_Size() int

func (*BatchPublishRequest) XXX_Unmarshal 

func (m *BatchPublishRequest) XXX_Unmarshal(b []byte) error

type DataSourceAdapterClient 

type DataSourceAdapterClient interface {
	BatchPublish(ctx context.Context, in *BatchPublishRequest, opts ...grpc.CallOption) (*BatchPublishReply, error)
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishReply, error)
	PublishEvents(ctx context.Context, opts ...grpc.CallOption) (DataSourceAdapter_PublishEventsClient, error)
}

DataSourceAdapterClient is the client API for DataSourceAdapter service.

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

func NewDataSourceAdapterClient 

func NewDataSourceAdapterClient(cc *grpc.ClientConn) DataSourceAdapterClient

type DataSourceAdapterServer 

type DataSourceAdapterServer interface {
	BatchPublish(context.Context, *BatchPublishRequest) (*BatchPublishReply, error)
	Publish(context.Context, *PublishRequest) (*PublishReply, error)
	PublishEvents(DataSourceAdapter_PublishEventsServer) error
}

DataSourceAdapterServer is the server API for DataSourceAdapter service.

type DataSourceAdapter_PublishEventsClient 

type DataSourceAdapter_PublishEventsClient interface {
	Send(*PublishRequest) error
	CloseAndRecv() (*PublishReply, error)
	grpc.ClientStream
}

type DataSourceAdapter_PublishEventsServer 

type DataSourceAdapter_PublishEventsServer interface {
	SendAndClose(*PublishReply) error
	Recv() (*PublishRequest, error)
	grpc.ServerStream
}

type PublishReply 

type PublishReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublishReply) Descriptor 

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

func (*PublishReply) GetReason 

func (m *PublishReply) GetReason() string

func (*PublishReply) GetSuccess 

func (m *PublishReply) GetSuccess() bool

func (*PublishReply) ProtoMessage 

func (*PublishReply) ProtoMessage()

func (*PublishReply) Reset 

func (m *PublishReply) Reset()

func (*PublishReply) String 

func (m *PublishReply) String() string

func (*PublishReply) XXX_DiscardUnknown 

func (m *PublishReply) XXX_DiscardUnknown()

func (*PublishReply) XXX_Marshal 

func (m *PublishReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishReply) XXX_Merge 

func (m *PublishReply) XXX_Merge(src proto.Message)

func (*PublishReply) XXX_Size 

func (m *PublishReply) XXX_Size() int

func (*PublishReply) XXX_Unmarshal 

func (m *PublishReply) XXX_Unmarshal(b []byte) error

type PublishRequest 

type PublishRequest struct {
	EventName            string            `protobuf:"bytes,1,opt,name=eventName,proto3" json:"eventName,omitempty"`
	Payload              []byte            `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Meta                 map[string][]byte `` /* 149-byte string literal not displayed */
	Source               string            `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Partition            int32             `protobuf:"varint,5,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset               int32             `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PublishRequest) Descriptor 

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

func (*PublishRequest) GetEventName 

func (m *PublishRequest) GetEventName() string

func (*PublishRequest) GetMeta 

func (m *PublishRequest) GetMeta() map[string][]byte

func (*PublishRequest) GetOffset 

func (m *PublishRequest) GetOffset() int32

func (*PublishRequest) GetPartition 

func (m *PublishRequest) GetPartition() int32

func (*PublishRequest) GetPayload 

func (m *PublishRequest) GetPayload() []byte

func (*PublishRequest) GetSource 

func (m *PublishRequest) GetSource() string

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset 

func (m *PublishRequest) Reset()

func (*PublishRequest) String 

func (m *PublishRequest) String() string

func (*PublishRequest) XXX_DiscardUnknown 

func (m *PublishRequest) XXX_DiscardUnknown()

func (*PublishRequest) XXX_Marshal 

func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishRequest) XXX_Merge 

func (m *PublishRequest) XXX_Merge(src proto.Message)

func (*PublishRequest) XXX_Size 

func (m *PublishRequest) XXX_Size() int

func (*PublishRequest) XXX_Unmarshal 

func (m *PublishRequest) XXX_Unmarshal(b []byte) error

type UnimplementedDataSourceAdapterServer 

type UnimplementedDataSourceAdapterServer struct {
}

UnimplementedDataSourceAdapterServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataSourceAdapterServer) BatchPublish 

func (*UnimplementedDataSourceAdapterServer) BatchPublish(ctx context.Context, req *BatchPublishRequest) (*BatchPublishReply, error)

func (*UnimplementedDataSourceAdapterServer) Publish 

func (*UnimplementedDataSourceAdapterServer) Publish(ctx context.Context, req *PublishRequest) (*PublishReply, error)

func (*UnimplementedDataSourceAdapterServer) PublishEvents 

func (*UnimplementedDataSourceAdapterServer) PublishEvents(srv DataSourceAdapter_PublishEventsServer) 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.