v1

package
v1.9.0 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2024 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Repeater_Stream_FullMethodName    = "/repeater.v1.Repeater/Stream"
	Repeater_LogStream_FullMethodName = "/repeater.v1.Repeater/LogStream"
)

Variables

View Source 
var (
	LogLevel_name = map[int32]string{
		0: "DEBUG",
		1: "INFO",
		2: "WARN",
		3: "ERROR",
	}
	LogLevel_value = map[string]int32{
		"DEBUG": 0,
		"INFO":  1,
		"WARN":  2,
		"ERROR": 3,
	}
)

Enum value maps for LogLevel.

View Source 
var File_repeater_v1_main_proto protoreflect.FileDescriptor
View Source 
var Repeater_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "repeater.v1.Repeater",
	HandlerType: (*RepeaterServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _Repeater_Stream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "LogStream",
			Handler:       _Repeater_LogStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "repeater/v1/main.proto",
}

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

Functions

func RegisterRepeaterServer 

func RegisterRepeaterServer(s grpc.ServiceRegistrar, srv RepeaterServer)

Types

type Log 

type Log struct {

	// date
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp"`
	// log level
	Level LogLevel `protobuf:"varint,2,opt,name=level,proto3,enum=repeater.v1.LogLevel" json:"level"`
	// log message
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetLevel 

func (x *Log) GetLevel() LogLevel

func (*Log) GetMessage 

func (x *Log) GetMessage() string

func (*Log) GetTimestamp 

func (x *Log) GetTimestamp() *timestamppb.Timestamp

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

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

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

type LogLevel 

type LogLevel int32
const (
	LogLevel_DEBUG LogLevel = 0
	LogLevel_INFO  LogLevel = 1
	LogLevel_WARN  LogLevel = 2
	LogLevel_ERROR LogLevel = 3
)

func (LogLevel) Descriptor 

func (LogLevel) Descriptor() protoreflect.EnumDescriptor

func (LogLevel) Enum 

func (x LogLevel) Enum() *LogLevel

func (LogLevel) EnumDescriptor deprecated 

func (LogLevel) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogLevel.Descriptor instead.

func (LogLevel) Number 

func (x LogLevel) Number() protoreflect.EnumNumber

func (LogLevel) String 

func (x LogLevel) String() string

func (LogLevel) Type 

func (LogLevel) Type() protoreflect.EnumType

type RepeaterClient 

type RepeaterClient interface {
	Stream(ctx context.Context, opts ...grpc.CallOption) (Repeater_StreamClient, error)
	LogStream(ctx context.Context, opts ...grpc.CallOption) (Repeater_LogStreamClient, error)
}

RepeaterClient is the client API for Repeater 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 NewRepeaterClient 

func NewRepeaterClient(cc grpc.ClientConnInterface) RepeaterClient

type RepeaterServer 

type RepeaterServer interface {
	Stream(Repeater_StreamServer) error
	LogStream(Repeater_LogStreamServer) error
	// contains filtered or unexported methods
}

RepeaterServer is the server API for Repeater service. All implementations must embed UnimplementedRepeaterServer for forward compatibility

type Repeater_LogStreamClient 

type Repeater_LogStreamClient interface {
	Send(*Log) error
	Recv() (*Log, error)
	grpc.ClientStream
}

type Repeater_LogStreamServer 

type Repeater_LogStreamServer interface {
	Send(*Log) error
	Recv() (*Log, error)
	grpc.ServerStream
}

type Repeater_StreamClient 

type Repeater_StreamClient interface {
	Send(*Response) error
	Recv() (*Request, error)
	grpc.ClientStream
}

type Repeater_StreamServer 

type Repeater_StreamServer interface {
	Send(*Request) error
	Recv() (*Response, error)
	grpc.ServerStream
}

type Request 

type Request struct {

	// TCP payload
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data"`
	// Need to pass URL as the data is the TCP payload
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url"`
	// link request and response
	Correlation int64 `protobuf:"varint,3,opt,name=correlation,proto3" json:"correlation"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetCorrelation 

func (x *Request) GetCorrelation() int64

func (*Request) GetData 

func (x *Request) GetData() []byte

func (*Request) GetUrl 

func (x *Request) GetUrl() string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Response 

type Response struct {

	// TCP response
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data"`
	// link request and response
	Correlation int64 `protobuf:"varint,3,opt,name=correlation,proto3" json:"correlation"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetCorrelation 

func (x *Response) GetCorrelation() int64

func (*Response) GetData 

func (x *Response) GetData() []byte

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type UnimplementedRepeaterServer 

type UnimplementedRepeaterServer struct {
}

UnimplementedRepeaterServer must be embedded to have forward compatible implementations.

func (UnimplementedRepeaterServer) LogStream 

func (UnimplementedRepeaterServer) LogStream(Repeater_LogStreamServer) error

func (UnimplementedRepeaterServer) Stream 

func (UnimplementedRepeaterServer) Stream(Repeater_StreamServer) error

type UnsafeRepeaterServer 

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

UnsafeRepeaterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RepeaterServer 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.