pb

type ConsReq struct {
	Proxy string `protobuf:"bytes,1,opt,name=proxy" json:"proxy,omitempty"`
	Topic string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
	Group string `protobuf:"bytes,3,opt,name=group" json:"group,omitempty"`
}

type ConsRes struct {
	Partition    int32  `protobuf:"varint,1,opt,name=partition" json:"partition,omitempty"`
	Offset       int64  `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
	KeyValue     []byte `protobuf:"bytes,3,opt,name=key_value,json=keyValue,proto3" json:"key_value,omitempty"`
	KeyUndefined bool   `protobuf:"varint,4,opt,name=key_undefined,json=keyUndefined" json:"key_undefined,omitempty"`
	Message      []byte `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
}

type KafkaPixyClient interface {
	Produce(ctx context.Context, in *ProdReq, opts ...grpc.CallOption) (*ProdRes, error)
	Consume(ctx context.Context, in *ConsReq, opts ...grpc.CallOption) (*ConsRes, error)
}

type KafkaPixyServer interface {
	Produce(context.Context, *ProdReq) (*ProdRes, error)
	Consume(context.Context, *ConsReq) (*ConsRes, error)
}

type ProdReq struct {
	Proxy        string `protobuf:"bytes,1,opt,name=proxy" json:"proxy,omitempty"`
	Topic        string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
	KeyValue     []byte `protobuf:"bytes,3,opt,name=key_value,json=keyValue,proto3" json:"key_value,omitempty"`
	KeyUndefined bool   `protobuf:"varint,4,opt,name=key_undefined,json=keyUndefined" json:"key_undefined,omitempty"`
	Message      []byte `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	AsyncMode    bool   `protobuf:"varint,6,opt,name=async_mode,json=asyncMode" json:"async_mode,omitempty"`
}

type ProdRes struct {
	Partition int32 `protobuf:"varint,1,opt,name=partition" json:"partition,omitempty"`
	Offset    int64 `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
}