mhubapi

Aug 15, 2018

Changes in this version

type AvailableDSKFStreamOutput

+ Id int64

+ func (m *AvailableDSKFStreamOutput) GetId() int64

type SetTaskStatusInput

+ Id int64

+ func (m *SetTaskStatusInput) GetId() int64

Aug 8, 2018

Changes in this version

+ var TaskStatus_name = map[int32]string

+ var TaskStatus_value = map[string]int32

+ func RegisterMicrologProxyHubServer(s *grpc.Server, srv MicrologProxyHubServer)

+ type AvailableDSKFStreamInput struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AvailableDSKFStreamInput) ProtoMessage()

+ func (dst *AvailableDSKFStreamInput) XXX_Merge(src proto.Message)

+ func (m *AvailableDSKFStreamInput) Reset()

+ func (m *AvailableDSKFStreamInput) String() string

+ func (m *AvailableDSKFStreamInput) XXX_DiscardUnknown()

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

+ func (m *AvailableDSKFStreamInput) XXX_Size() int

+ func (m *AvailableDSKFStreamInput) XXX_Unmarshal(b []byte) error

+ type AvailableDSKFStreamOutput struct

+ DskfFile string

+ TaskId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AvailableDSKFStreamOutput) ProtoMessage()

+ func (dst *AvailableDSKFStreamOutput) XXX_Merge(src proto.Message)

+ func (m *AvailableDSKFStreamOutput) GetDskfFile() string

+ func (m *AvailableDSKFStreamOutput) GetTaskId() string

+ func (m *AvailableDSKFStreamOutput) Reset()

+ func (m *AvailableDSKFStreamOutput) String() string

+ func (m *AvailableDSKFStreamOutput) XXX_DiscardUnknown()

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

+ func (m *AvailableDSKFStreamOutput) XXX_Size() int

+ func (m *AvailableDSKFStreamOutput) XXX_Unmarshal(b []byte) error

+ type DeepPingOutput struct

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeepPingOutput) ProtoMessage()

+ func (dst *DeepPingOutput) XXX_Merge(src proto.Message)

+ func (m *DeepPingOutput) GetValue() string

+ func (m *DeepPingOutput) Reset()

+ func (m *DeepPingOutput) String() string

+ func (m *DeepPingOutput) XXX_DiscardUnknown()

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

+ func (m *DeepPingOutput) XXX_Size() int

+ func (m *DeepPingOutput) XXX_Unmarshal(b []byte) error

+ type MicrologProxyHubClient interface

+ AvailableDSKFStream func(ctx context.Context, in *AvailableDSKFStreamInput, opts ...grpc.CallOption) (MicrologProxyHub_AvailableDSKFStreamClient, error)

+ DeepPing func(ctx context.Context, in *Void, opts ...grpc.CallOption) (*DeepPingOutput, error)

+ SetTaskStatus func(ctx context.Context, in *SetTaskStatusInput, opts ...grpc.CallOption) (*Void, error)

+ func NewMicrologProxyHubClient(cc *grpc.ClientConn) MicrologProxyHubClient

+ type MicrologProxyHubServer interface

+ AvailableDSKFStream func(*AvailableDSKFStreamInput, MicrologProxyHub_AvailableDSKFStreamServer) error

+ DeepPing func(context.Context, *Void) (*DeepPingOutput, error)

+ SetTaskStatus func(context.Context, *SetTaskStatusInput) (*Void, error)

+ type MicrologProxyHub_AvailableDSKFStreamClient interface

+ Recv func() (*AvailableDSKFStreamOutput, error)

+ type MicrologProxyHub_AvailableDSKFStreamServer interface

+ Send func(*AvailableDSKFStreamOutput) error

+ type SetTaskStatusInput struct

+ Status TaskStatus

+ TaskId string

+ UserId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SetTaskStatusInput) ProtoMessage()

+ func (dst *SetTaskStatusInput) XXX_Merge(src proto.Message)

+ func (m *SetTaskStatusInput) GetStatus() TaskStatus

+ func (m *SetTaskStatusInput) GetTaskId() string

+ func (m *SetTaskStatusInput) GetUserId() string

+ func (m *SetTaskStatusInput) Reset()

+ func (m *SetTaskStatusInput) String() string

+ func (m *SetTaskStatusInput) XXX_DiscardUnknown()

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

+ func (m *SetTaskStatusInput) XXX_Size() int

+ func (m *SetTaskStatusInput) XXX_Unmarshal(b []byte) error

+ type TaskStatus int32

+ const TaskStatus_COMPLETED

+ const TaskStatus_NOT_SENT

+ const TaskStatus_RECEIVED

+ const TaskStatus_SENT

+ func (TaskStatus) EnumDescriptor() ([]byte, []int)

+ func (x TaskStatus) String() string

+ type Void struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Void) ProtoMessage()

+ func (dst *Void) XXX_Merge(src proto.Message)

+ func (m *Void) Reset()

+ func (m *Void) String() string

+ func (m *Void) XXX_DiscardUnknown()

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

+ func (m *Void) XXX_Size() int

+ func (m *Void) XXX_Unmarshal(b []byte) error