protos

package
v0.0.0-...-a136232 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Events_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protos.Events",
	HandlerType: (*EventsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Health",
			Handler:    _Events_Health_Handler,
		},
		{
			MethodName: "Pub",
			Handler:    _Events_Pub_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Sub",
			Handler:       _Events_Sub_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "events.proto",
}

Events_ServiceDesc is the grpc.ServiceDesc for Events service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_events_proto protoreflect.FileDescriptor

Functions

func RegisterEventsServer 

func RegisterEventsServer(s grpc.ServiceRegistrar, srv EventsServer)

Types

type EventsClient 

type EventsClient interface {
	Health(ctx context.Context, in *HealthReq, opts ...grpc.CallOption) (*HealthRes, error)
	Pub(ctx context.Context, in *PubReq, opts ...grpc.CallOption) (*PubRes, error)
	Sub(ctx context.Context, in *SubReq, opts ...grpc.CallOption) (Events_SubClient, error)
}

EventsClient is the client API for Events service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewEventsClient 

func NewEventsClient(cc grpc.ClientConnInterface) EventsClient

type EventsServer 

type EventsServer interface {
	Health(context.Context, *HealthReq) (*HealthRes, error)
	Pub(context.Context, *PubReq) (*PubRes, error)
	Sub(*SubReq, Events_SubServer) error
	// contains filtered or unexported methods
}

EventsServer is the server API for Events service. All implementations must embed UnimplementedEventsServer for forward compatibility

type Events_SubClient 

type Events_SubClient interface {
	Recv() (*SubRes, error)
	grpc.ClientStream
}

type Events_SubServer 

type Events_SubServer interface {
	Send(*SubRes) error
	grpc.ServerStream
}

type HealthReq 

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

func (*HealthReq) Descriptor deprecated 

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

Deprecated: Use HealthReq.ProtoReflect.Descriptor instead.

func (*HealthReq) ProtoMessage 

func (*HealthReq) ProtoMessage()

func (*HealthReq) ProtoReflect 

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

func (*HealthReq) Reset 

func (x *HealthReq) Reset()

func (*HealthReq) String 

func (x *HealthReq) String() string

type HealthRes 

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

func (*HealthRes) Descriptor deprecated 

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

Deprecated: Use HealthRes.ProtoReflect.Descriptor instead.

func (*HealthRes) GetHost 

func (x *HealthRes) GetHost() string

func (*HealthRes) GetVersion 

func (x *HealthRes) GetVersion() string

func (*HealthRes) ProtoMessage 

func (*HealthRes) ProtoMessage()

func (*HealthRes) ProtoReflect 

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

func (*HealthRes) Reset 

func (x *HealthRes) Reset()

func (*HealthRes) String 

func (x *HealthRes) String() string

type PubReq 

type PubReq struct {
	Workspace string `protobuf:"bytes,1,opt,name=workspace,proto3" json:"workspace,omitempty"`
	App       string `protobuf:"bytes,2,opt,name=app,proto3" json:"app,omitempty"`
	Type      string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Data      string `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PubReq) Descriptor deprecated 

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

Deprecated: Use PubReq.ProtoReflect.Descriptor instead.

func (*PubReq) GetApp 

func (x *PubReq) GetApp() string

func (*PubReq) GetData 

func (x *PubReq) GetData() string

func (*PubReq) GetType 

func (x *PubReq) GetType() string

func (*PubReq) GetWorkspace 

func (x *PubReq) GetWorkspace() string

func (*PubReq) ProtoMessage 

func (*PubReq) ProtoMessage()

func (*PubReq) ProtoReflect 

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

func (*PubReq) Reset 

func (x *PubReq) Reset()

func (*PubReq) String 

func (x *PubReq) String() string

type PubRes 

type PubRes struct {
	Pubkey     string `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	Bucket     string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Timestamps int64  `protobuf:"varint,3,opt,name=timestamps,proto3" json:"timestamps,omitempty"`
	// contains filtered or unexported fields
}

func (*PubRes) Descriptor deprecated 

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

Deprecated: Use PubRes.ProtoReflect.Descriptor instead.

func (*PubRes) GetBucket 

func (x *PubRes) GetBucket() string

func (*PubRes) GetPubkey 

func (x *PubRes) GetPubkey() string

func (*PubRes) GetTimestamps 

func (x *PubRes) GetTimestamps() int64

func (*PubRes) ProtoMessage 

func (*PubRes) ProtoMessage()

func (*PubRes) ProtoReflect 

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

func (*PubRes) Reset 

func (x *PubRes) Reset()

func (*PubRes) String 

func (x *PubRes) String() string

type SubReq 

type SubReq struct {
	Workspace string `protobuf:"bytes,1,opt,name=workspace,proto3" json:"workspace,omitempty"`
	App       string `protobuf:"bytes,2,opt,name=app,proto3" json:"app,omitempty"`
	Type      string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*SubReq) Descriptor deprecated 

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

Deprecated: Use SubReq.ProtoReflect.Descriptor instead.

func (*SubReq) GetApp 

func (x *SubReq) GetApp() string

func (*SubReq) GetType 

func (x *SubReq) GetType() string

func (*SubReq) GetWorkspace 

func (x *SubReq) GetWorkspace() string

func (*SubReq) ProtoMessage 

func (*SubReq) ProtoMessage()

func (*SubReq) ProtoReflect 

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

func (*SubReq) Reset 

func (x *SubReq) Reset()

func (*SubReq) String 

func (x *SubReq) String() string

type SubRes 

type SubRes struct {
	Bucket     string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Workspace  string `protobuf:"bytes,2,opt,name=workspace,proto3" json:"workspace,omitempty"`
	App        string `protobuf:"bytes,3,opt,name=app,proto3" json:"app,omitempty"`
	Type       string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Id         string `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`
	Timestamps int64  `protobuf:"varint,6,opt,name=timestamps,proto3" json:"timestamps,omitempty"`
	Data       string `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SubRes) Descriptor deprecated 

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

Deprecated: Use SubRes.ProtoReflect.Descriptor instead.

func (*SubRes) GetApp 

func (x *SubRes) GetApp() string

func (*SubRes) GetBucket 

func (x *SubRes) GetBucket() string

func (*SubRes) GetData 

func (x *SubRes) GetData() string

func (*SubRes) GetId 

func (x *SubRes) GetId() string

func (*SubRes) GetTimestamps 

func (x *SubRes) GetTimestamps() int64

func (*SubRes) GetType 

func (x *SubRes) GetType() string

func (*SubRes) GetWorkspace 

func (x *SubRes) GetWorkspace() string

func (*SubRes) ProtoMessage 

func (*SubRes) ProtoMessage()

func (*SubRes) ProtoReflect 

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

func (*SubRes) Reset 

func (x *SubRes) Reset()

func (*SubRes) String 

func (x *SubRes) String() string

type UnimplementedEventsServer 

type UnimplementedEventsServer struct {
}

UnimplementedEventsServer must be embedded to have forward compatible implementations.

func (UnimplementedEventsServer) Health 

func (UnimplementedEventsServer) Health(context.Context, *HealthReq) (*HealthRes, error)

func (UnimplementedEventsServer) Pub 

func (UnimplementedEventsServer) Pub(context.Context, *PubReq) (*PubRes, error)

func (UnimplementedEventsServer) Sub 

func (UnimplementedEventsServer) Sub(*SubReq, Events_SubServer) error

type UnsafeEventsServer 

type UnsafeEventsServer interface {
	// contains filtered or unexported methods
}

UnsafeEventsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventsServer will result in compilation errors.

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.