eventstreamspec

package

Go to main page

Versions in this module

v0

v0.5.4

Jul 16, 2024

v0.5.3

Jun 12, 2023

Changes in this version

+ const StreamAPI_Consume_FullMethodName

+ const StreamAPI_EventTypes_FullMethodName

v0.5.2

Sep 19, 2022

v0.5.1

Aug 19, 2022

Changes in this version

+ var StreamAPI_ServiceDesc = grpc.ServiceDesc

+ type UnsafeStreamAPIServer interface

v0.5.0

Jan 19, 2021

Changes in this version

type EventTypesRequest

+ ApplicationKey string

+ func (x *EventTypesRequest) GetApplicationKey() string

+ type UnsupportedStartPoint struct

+ func (*UnsupportedStartPoint) Descriptor() ([]byte, []int)

+ func (*UnsupportedStartPoint) ProtoMessage()

+ func (x *UnsupportedStartPoint) ProtoReflect() protoreflect.Message

+ func (x *UnsupportedStartPoint) Reset()

+ func (x *UnsupportedStartPoint) String() string

v0.4.0

Dec 22, 2020

v0.3.0

Dec 22, 2020

v0.2.1

Dec 22, 2020

v0.2.0

Dec 20, 2020

v0.1.0

Dec 20, 2020

Changes in this version

+ var File_github_com_dogmatiq_interopspec_eventstreamspec_streamapi_proto protoreflect.FileDescriptor

+ func RegisterStreamAPIServer(s *grpc.Server, srv StreamAPIServer)

+ type ConsumeRequest struct

+ ApplicationKey string

+ EventTypes []*EventType

+ StartPoint isConsumeRequest_StartPoint

+ func (*ConsumeRequest) Descriptor() ([]byte, []int)

+ func (*ConsumeRequest) ProtoMessage()

+ func (m *ConsumeRequest) GetStartPoint() isConsumeRequest_StartPoint

+ func (x *ConsumeRequest) GetApplicationKey() string

+ func (x *ConsumeRequest) GetEventTypes() []*EventType

+ func (x *ConsumeRequest) GetOffset() uint64

+ func (x *ConsumeRequest) ProtoReflect() protoreflect.Message

+ func (x *ConsumeRequest) Reset()

+ func (x *ConsumeRequest) String() string

+ type ConsumeRequest_Offset struct

+ Offset uint64

+ type ConsumeResponse struct

+ Envelope *envelopespec.Envelope

+ Offset uint64

+ func (*ConsumeResponse) Descriptor() ([]byte, []int)

+ func (*ConsumeResponse) ProtoMessage()

+ func (x *ConsumeResponse) GetEnvelope() *envelopespec.Envelope

+ func (x *ConsumeResponse) GetOffset() uint64

+ func (x *ConsumeResponse) ProtoReflect() protoreflect.Message

+ func (x *ConsumeResponse) Reset()

+ func (x *ConsumeResponse) String() string

+ type EventType struct

+ MediaTypes []string

+ PortableName string

+ func (*EventType) Descriptor() ([]byte, []int)

+ func (*EventType) ProtoMessage()

+ func (x *EventType) GetMediaTypes() []string

+ func (x *EventType) GetPortableName() string

+ func (x *EventType) ProtoReflect() protoreflect.Message

+ func (x *EventType) Reset()

+ func (x *EventType) String() string

+ type EventTypesRequest struct

+ func (*EventTypesRequest) Descriptor() ([]byte, []int)

+ func (*EventTypesRequest) ProtoMessage()

+ func (x *EventTypesRequest) ProtoReflect() protoreflect.Message

+ func (x *EventTypesRequest) Reset()

+ func (x *EventTypesRequest) String() string

+ type EventTypesResponse struct

+ EventTypes []*EventType

+ func (*EventTypesResponse) Descriptor() ([]byte, []int)

+ func (*EventTypesResponse) ProtoMessage()

+ func (x *EventTypesResponse) GetEventTypes() []*EventType

+ func (x *EventTypesResponse) ProtoReflect() protoreflect.Message

+ func (x *EventTypesResponse) Reset()

+ func (x *EventTypesResponse) String() string

+ type NoRecognizedMediaTypes struct

+ PortableName string

+ func (*NoRecognizedMediaTypes) Descriptor() ([]byte, []int)

+ func (*NoRecognizedMediaTypes) ProtoMessage()

+ func (x *NoRecognizedMediaTypes) GetPortableName() string

+ func (x *NoRecognizedMediaTypes) ProtoReflect() protoreflect.Message

+ func (x *NoRecognizedMediaTypes) Reset()

+ func (x *NoRecognizedMediaTypes) String() string

+ type StreamAPIClient interface

+ Consume func(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (StreamAPI_ConsumeClient, error)

+ EventTypes func(ctx context.Context, in *EventTypesRequest, opts ...grpc.CallOption) (*EventTypesResponse, error)

+ func NewStreamAPIClient(cc grpc.ClientConnInterface) StreamAPIClient

+ type StreamAPIServer interface

+ Consume func(*ConsumeRequest, StreamAPI_ConsumeServer) error

+ EventTypes func(context.Context, *EventTypesRequest) (*EventTypesResponse, error)

+ type StreamAPI_ConsumeClient interface

+ Recv func() (*ConsumeResponse, error)

+ type StreamAPI_ConsumeServer interface

+ Send func(*ConsumeResponse) error

+ type UnimplementedStartPointMechanism struct

+ func (*UnimplementedStartPointMechanism) Descriptor() ([]byte, []int)

+ func (*UnimplementedStartPointMechanism) ProtoMessage()

+ func (x *UnimplementedStartPointMechanism) ProtoReflect() protoreflect.Message

+ func (x *UnimplementedStartPointMechanism) Reset()

+ func (x *UnimplementedStartPointMechanism) String() string

+ type UnimplementedStreamAPIServer struct

+ func (*UnimplementedStreamAPIServer) Consume(*ConsumeRequest, StreamAPI_ConsumeServer) error

+ func (*UnimplementedStreamAPIServer) EventTypes(context.Context, *EventTypesRequest) (*EventTypesResponse, error)

+ type UnrecognizedApplication struct

+ ApplicationKey string

+ func (*UnrecognizedApplication) Descriptor() ([]byte, []int)

+ func (*UnrecognizedApplication) ProtoMessage()

+ func (x *UnrecognizedApplication) GetApplicationKey() string

+ func (x *UnrecognizedApplication) ProtoReflect() protoreflect.Message

+ func (x *UnrecognizedApplication) Reset()

+ func (x *UnrecognizedApplication) String() string

+ type UnrecognizedEventType struct

+ PortableName string

+ func (*UnrecognizedEventType) Descriptor() ([]byte, []int)

+ func (*UnrecognizedEventType) ProtoMessage()

+ func (x *UnrecognizedEventType) GetPortableName() string

+ func (x *UnrecognizedEventType) ProtoReflect() protoreflect.Message

+ func (x *UnrecognizedEventType) Reset()

+ func (x *UnrecognizedEventType) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL