proto

type IsLeaderResp struct {
	IsLeader bool `protobuf:"varint,1,opt,name=isLeader,proto3" json:"isLeader,omitempty"`
	// contains filtered or unexported fields
}

type StreamObj struct {

	// Types that are assignable to Event:
	//	*StreamObj_Start_
	//	*StreamObj_Open_
	//	*StreamObj_Input_
	Event isStreamObj_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

type StreamObj_Input struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type StreamObj_Input_ struct {
	Input *StreamObj_Input `protobuf:"bytes,3,opt,name=input,proto3,oneof"`
}

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

type StreamObj_Open_ struct {
	Open *StreamObj_Open `protobuf:"bytes,2,opt,name=open,proto3,oneof"`
}

type StreamObj_Start struct {
	Channel StreamObj_Start_Channel `protobuf:"varint,1,opt,name=channel,proto3,enum=proto.StreamObj_Start_Channel" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

type StreamObj_Start_ struct {
	Start *StreamObj_Start `protobuf:"bytes,1,opt,name=start,proto3,oneof"`
}

type StreamObj_Start_Channel int32

type SystemServiceClient interface {
	Stream(ctx context.Context, opts ...grpc.CallOption) (SystemService_StreamClient, error)
	IsLeader(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*IsLeaderResp, error)
}

type SystemServiceServer interface {
	Stream(SystemService_StreamServer) error
	IsLeader(context.Context, *empty.Empty) (*IsLeaderResp, error)
}

type SystemService_StreamClient interface {
	Send(*StreamObj) error
	Recv() (*StreamObj, error)
	grpc.ClientStream
}

type SystemService_StreamServer interface {
	Send(*StreamObj) error
	Recv() (*StreamObj, error)
	grpc.ServerStream
}

type UnimplementedSystemServiceServer struct {
}