pb

type Change struct {
	Mode  Mode      `protobuf:"varint,1,opt,name=mode,proto3,enum=transistor.v1.Mode" json:"mode,omitempty"`
	Op    Operation `protobuf:"varint,2,opt,name=op,proto3,enum=transistor.v1.Operation" json:"op,omitempty"`
	Topic *Topic    `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type CommandRequest struct {
	Args []string `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

type CommandResponse struct {
	Line string `protobuf:"bytes,1,opt,name=line,proto3" json:"line,omitempty"`
	// contains filtered or unexported fields
}

type Message struct {
	Mode      Mode                   `protobuf:"varint,1,opt,name=mode,proto3,enum=transistor.v1.Mode" json:"mode,omitempty"`
	Topic     *Topic                 `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Method    Method                 `protobuf:"varint,3,opt,name=method,proto3,enum=transistor.v1.Method" json:"method,omitempty"`
	Data      *anypb.Any             `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type Method int32

type Mode int32

type Operation int32

type PublishRequest struct {
	Msg *Message `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

type PublishResponse struct {
	Change []*Change `protobuf:"bytes,1,rep,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeRequest struct {
	Change *Change `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeResponse struct {
	Msg *Message `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

type Topic struct {
	Tokens []string `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
	// contains filtered or unexported fields
}

type TransistorServiceClient interface {
	// Open a new command line interface
	Command(ctx context.Context, in *CommandRequest, opts ...grpc.CallOption) (TransistorService_CommandClient, error)
	// Receive a stream from a non-cluster node
	Publish(ctx context.Context, opts ...grpc.CallOption) (TransistorService_PublishClient, error)
	// Receive a stream from both cluster/non-cluster nodes
	// Always the subscriber should approach to this server
	Subscribe(ctx context.Context, opts ...grpc.CallOption) (TransistorService_SubscribeClient, error)
}

type TransistorServiceServer interface {
	// Open a new command line interface
	Command(*CommandRequest, TransistorService_CommandServer) error
	// Receive a stream from a non-cluster node
	Publish(TransistorService_PublishServer) error
	// Receive a stream from both cluster/non-cluster nodes
	// Always the subscriber should approach to this server
	Subscribe(TransistorService_SubscribeServer) error
	// contains filtered or unexported methods
}

type TransistorService_CommandClient interface {
	Recv() (*CommandResponse, error)
	grpc.ClientStream
}

type TransistorService_CommandServer interface {
	Send(*CommandResponse) error
	grpc.ServerStream
}

type TransistorService_PublishClient interface {
	Send(*PublishRequest) error
	CloseAndRecv() (*PublishResponse, error)
	grpc.ClientStream
}

type TransistorService_PublishServer interface {
	SendAndClose(*PublishResponse) error
	Recv() (*PublishRequest, error)
	grpc.ServerStream
}

type TransistorService_SubscribeClient interface {
	Send(*SubscribeRequest) error
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type TransistorService_SubscribeServer interface {
	Send(*SubscribeResponse) error
	Recv() (*SubscribeRequest, error)
	grpc.ServerStream
}

type UnimplementedTransistorServiceServer struct {
}

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