rpc

package
v0.0.0-...-2662bf7 Latest Latest
Warning

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

Go to latest
Published: Apr 5, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterLogUnitServiceServer

func RegisterLogUnitServiceServer(s *grpc.Server, srv LogUnitServiceServer)

Types

type DefaultLogUnitService

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

func (*DefaultLogUnitService) GetUnits

func (*DefaultLogUnitService) NLines

func (*DefaultLogUnitService) NLogs

func (*DefaultLogUnitService) TLogs

type Empty

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor

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

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) Reset

func (m *Empty) Reset()

func (*Empty) String

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal

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

func (*Empty) XXX_Merge

func (dst *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal

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

type LogRS

type LogRS struct {
	Log                  string   `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogRS) Descriptor

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

func (*LogRS) GetLog

func (m *LogRS) GetLog() string

func (*LogRS) ProtoMessage

func (*LogRS) ProtoMessage()

func (*LogRS) Reset

func (m *LogRS) Reset()

func (*LogRS) String

func (m *LogRS) String() string

func (*LogRS) XXX_DiscardUnknown

func (m *LogRS) XXX_DiscardUnknown()

func (*LogRS) XXX_Marshal

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

func (*LogRS) XXX_Merge

func (dst *LogRS) XXX_Merge(src proto.Message)

func (*LogRS) XXX_Size

func (m *LogRS) XXX_Size() int

func (*LogRS) XXX_Unmarshal

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

type LogUnitServiceClient

type LogUnitServiceClient interface {
	GetUnits(ctx context.Context, in *Empty, opts ...grpc.CallOption) (LogUnitService_GetUnitsClient, error)
	NLines(ctx context.Context, in *NLineRQ, opts ...grpc.CallOption) (LogUnitService_NLinesClient, error)
	NLogs(ctx context.Context, in *NLogRQ, opts ...grpc.CallOption) (LogUnitService_NLogsClient, error)
	TLogs(ctx context.Context, in *TLogRQ, opts ...grpc.CallOption) (LogUnitService_TLogsClient, error)
}

LogUnitServiceClient is the client API for LogUnitService service.

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

func NewLogUnitServiceClient

func NewLogUnitServiceClient(cc *grpc.ClientConn) LogUnitServiceClient

type LogUnitServiceServer

LogUnitServiceServer is the server API for LogUnitService service.

func NewLogService

func NewLogService(logUnits unit.LogUnits) (LogUnitServiceServer, error)

type LogUnitService_GetUnitsClient

type LogUnitService_GetUnitsClient interface {
	Recv() (*UnitRS, error)
	grpc.ClientStream
}

type LogUnitService_GetUnitsServer

type LogUnitService_GetUnitsServer interface {
	Send(*UnitRS) error
	grpc.ServerStream
}

type LogUnitService_NLinesClient

type LogUnitService_NLinesClient interface {
	Recv() (*NLineRS, error)
	grpc.ClientStream
}

type LogUnitService_NLinesServer

type LogUnitService_NLinesServer interface {
	Send(*NLineRS) error
	grpc.ServerStream
}

type LogUnitService_NLogsClient

type LogUnitService_NLogsClient interface {
	Recv() (*LogRS, error)
	grpc.ClientStream
}

type LogUnitService_NLogsServer

type LogUnitService_NLogsServer interface {
	Send(*LogRS) error
	grpc.ServerStream
}

type LogUnitService_TLogsClient

type LogUnitService_TLogsClient interface {
	Recv() (*LogRS, error)
	grpc.ClientStream
}

type LogUnitService_TLogsServer

type LogUnitService_TLogsServer interface {
	Send(*LogRS) error
	grpc.ServerStream
}

type NLineRQ

type NLineRQ struct {
	UnitId               string   `protobuf:"bytes,1,opt,name=unit_id,json=unitId,proto3" json:"unit_id,omitempty"`
	Count                int32    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NLineRQ) Descriptor

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

func (*NLineRQ) GetCount

func (m *NLineRQ) GetCount() int32

func (*NLineRQ) GetUnitId

func (m *NLineRQ) GetUnitId() string

func (*NLineRQ) ProtoMessage

func (*NLineRQ) ProtoMessage()

func (*NLineRQ) Reset

func (m *NLineRQ) Reset()

func (*NLineRQ) String

func (m *NLineRQ) String() string

func (*NLineRQ) XXX_DiscardUnknown

func (m *NLineRQ) XXX_DiscardUnknown()

func (*NLineRQ) XXX_Marshal

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

func (*NLineRQ) XXX_Merge

func (dst *NLineRQ) XXX_Merge(src proto.Message)

func (*NLineRQ) XXX_Size

func (m *NLineRQ) XXX_Size() int

func (*NLineRQ) XXX_Unmarshal

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

type NLineRS

type NLineRS struct {
	Line                 string   `protobuf:"bytes,1,opt,name=line,proto3" json:"line,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NLineRS) Descriptor

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

func (*NLineRS) GetLine

func (m *NLineRS) GetLine() string

func (*NLineRS) ProtoMessage

func (*NLineRS) ProtoMessage()

func (*NLineRS) Reset

func (m *NLineRS) Reset()

func (*NLineRS) String

func (m *NLineRS) String() string

func (*NLineRS) XXX_DiscardUnknown

func (m *NLineRS) XXX_DiscardUnknown()

func (*NLineRS) XXX_Marshal

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

func (*NLineRS) XXX_Merge

func (dst *NLineRS) XXX_Merge(src proto.Message)

func (*NLineRS) XXX_Size

func (m *NLineRS) XXX_Size() int

func (*NLineRS) XXX_Unmarshal

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

type NLogRQ

type NLogRQ struct {
	UnitId               string   `protobuf:"bytes,1,opt,name=unit_id,json=unitId,proto3" json:"unit_id,omitempty"`
	Count                int32    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	LogPattern           string   `protobuf:"bytes,3,opt,name=log_pattern,json=logPattern,proto3" json:"log_pattern,omitempty"`
	DateTimeLayout       string   `protobuf:"bytes,4,opt,name=date_time_layout,json=dateTimeLayout,proto3" json:"date_time_layout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NLogRQ) Descriptor

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

func (*NLogRQ) GetCount

func (m *NLogRQ) GetCount() int32

func (*NLogRQ) GetDateTimeLayout

func (m *NLogRQ) GetDateTimeLayout() string

func (*NLogRQ) GetLogPattern

func (m *NLogRQ) GetLogPattern() string

func (*NLogRQ) GetUnitId

func (m *NLogRQ) GetUnitId() string

func (*NLogRQ) ProtoMessage

func (*NLogRQ) ProtoMessage()

func (*NLogRQ) Reset

func (m *NLogRQ) Reset()

func (*NLogRQ) String

func (m *NLogRQ) String() string

func (*NLogRQ) XXX_DiscardUnknown

func (m *NLogRQ) XXX_DiscardUnknown()

func (*NLogRQ) XXX_Marshal

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

func (*NLogRQ) XXX_Merge

func (dst *NLogRQ) XXX_Merge(src proto.Message)

func (*NLogRQ) XXX_Size

func (m *NLogRQ) XXX_Size() int

func (*NLogRQ) XXX_Unmarshal

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

type TLogRQ

type TLogRQ struct {
	UnitId               string   `protobuf:"bytes,1,opt,name=unit_id,json=unitId,proto3" json:"unit_id,omitempty"`
	Offset               int64    `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Duration             string   `protobuf:"bytes,4,opt,name=duration,proto3" json:"duration,omitempty"`
	LogPattern           string   `protobuf:"bytes,5,opt,name=log_pattern,json=logPattern,proto3" json:"log_pattern,omitempty"`
	DateTimeLayout       string   `protobuf:"bytes,6,opt,name=date_time_layout,json=dateTimeLayout,proto3" json:"date_time_layout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TLogRQ) Descriptor

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

func (*TLogRQ) GetDateTimeLayout

func (m *TLogRQ) GetDateTimeLayout() string

func (*TLogRQ) GetDuration

func (m *TLogRQ) GetDuration() string

func (*TLogRQ) GetLogPattern

func (m *TLogRQ) GetLogPattern() string

func (*TLogRQ) GetOffset

func (m *TLogRQ) GetOffset() int64

func (*TLogRQ) GetUnitId

func (m *TLogRQ) GetUnitId() string

func (*TLogRQ) ProtoMessage

func (*TLogRQ) ProtoMessage()

func (*TLogRQ) Reset

func (m *TLogRQ) Reset()

func (*TLogRQ) String

func (m *TLogRQ) String() string

func (*TLogRQ) XXX_DiscardUnknown

func (m *TLogRQ) XXX_DiscardUnknown()

func (*TLogRQ) XXX_Marshal

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

func (*TLogRQ) XXX_Merge

func (dst *TLogRQ) XXX_Merge(src proto.Message)

func (*TLogRQ) XXX_Size

func (m *TLogRQ) XXX_Size() int

func (*TLogRQ) XXX_Unmarshal

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

type UnitRS

type UnitRS struct {
	Unit                 string   `protobuf:"bytes,1,opt,name=unit,proto3" json:"unit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnitRS) Descriptor

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

func (*UnitRS) GetUnit

func (m *UnitRS) GetUnit() string

func (*UnitRS) ProtoMessage

func (*UnitRS) ProtoMessage()

func (*UnitRS) Reset

func (m *UnitRS) Reset()

func (*UnitRS) String

func (m *UnitRS) String() string

func (*UnitRS) XXX_DiscardUnknown

func (m *UnitRS) XXX_DiscardUnknown()

func (*UnitRS) XXX_Marshal

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

func (*UnitRS) XXX_Merge

func (dst *UnitRS) XXX_Merge(src proto.Message)

func (*UnitRS) XXX_Size

func (m *UnitRS) XXX_Size() int

func (*UnitRS) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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