handler

type AckUpdate struct {
	QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Id        []byte `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type AddRoute struct {
	QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	RouteName string `protobuf:"bytes,2,opt,name=routeName,proto3" json:"routeName,omitempty"`
	// contains filtered or unexported fields
}

type AssignRoleRequest struct {
	Role     string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// contains filtered or unexported fields
}

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

type BatchAckUpdate struct {
	QueueName string   `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Id        [][]byte `protobuf:"bytes,2,rep,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type BatchMessages struct {
	Messages []*MessageInfo `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

type BatchNackUpdate struct {
	QueueName string   `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Ids       [][]byte `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

type ChangeCredentials struct {
	Username    string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	OldPassword string `protobuf:"bytes,2,opt,name=oldPassword,proto3" json:"oldPassword,omitempty"`
	NewPassword string `protobuf:"bytes,3,opt,name=newPassword,proto3" json:"newPassword,omitempty"`
	// contains filtered or unexported fields
}

type Config struct {
	TimeoutSec      int
	TimeoutAttempts int
}

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

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

type Credentials struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

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

type DeleteRoute struct {
	QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	RouteName string `protobuf:"bytes,2,opt,name=routeName,proto3" json:"routeName,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

type MQEndpointsClient interface {
	GetMessages(ctx context.Context, in *RequestMessageData, opts ...grpc.CallOption) (*MessageCollection, error)
	SubmitMessage(ctx context.Context, in *MessageInfo, opts ...grpc.CallOption) (*Status, error)
	CreateQueue(ctx context.Context, in *QueueInfo, opts ...grpc.CallOption) (*Status, error)
	Ack(ctx context.Context, in *AckUpdate, opts ...grpc.CallOption) (*Status, error)
	Login(ctx context.Context, in *Credentials, opts ...grpc.CallOption) (*Status, error)
	ChangePassword(ctx context.Context, in *ChangeCredentials, opts ...grpc.CallOption) (*Status, error)
	Nack(ctx context.Context, in *AckUpdate, opts ...grpc.CallOption) (*Status, error)
	DeleteQueue(ctx context.Context, in *DeleteQueueInfo, opts ...grpc.CallOption) (*Status, error)
	AddRoutingKey(ctx context.Context, in *AddRoute, opts ...grpc.CallOption) (*Status, error)
	DeleteRoutingKey(ctx context.Context, in *DeleteRoute, opts ...grpc.CallOption) (*Status, error)
	CreateUser(ctx context.Context, in *UserCreds, opts ...grpc.CallOption) (*Status, error)
	SubmitBatchedMessages(ctx context.Context, in *BatchMessages, opts ...grpc.CallOption) (*Status, error)
	IsLeaderNode(ctx context.Context, in *LeaderNodeRequest, opts ...grpc.CallOption) (*Status, error)
	DeleteUser(ctx context.Context, in *UserInformation, opts ...grpc.CallOption) (*Status, error)
	BatchAck(ctx context.Context, in *BatchAckUpdate, opts ...grpc.CallOption) (*Status, error)
	BatchNack(ctx context.Context, in *BatchNackUpdate, opts ...grpc.CallOption) (*Status, error)
	LogOut(ctx context.Context, in *LogOutRequest, opts ...grpc.CallOption) (*LogOutResponse, error)
	CreateRole(ctx context.Context, in *CreateRoleRequest, opts ...grpc.CallOption) (*CreateRoleResponse, error)
	AssignRole(ctx context.Context, in *AssignRoleRequest, opts ...grpc.CallOption) (*AssignRoleResponse, error)
	UnassignRole(ctx context.Context, in *UnassignRoleRequest, opts ...grpc.CallOption) (*UnassignRoleResponse, error)
}

type MQEndpointsServer interface {
	GetMessages(context.Context, *RequestMessageData) (*MessageCollection, error)
	SubmitMessage(context.Context, *MessageInfo) (*Status, error)
	CreateQueue(context.Context, *QueueInfo) (*Status, error)
	Ack(context.Context, *AckUpdate) (*Status, error)
	Login(context.Context, *Credentials) (*Status, error)
	ChangePassword(context.Context, *ChangeCredentials) (*Status, error)
	Nack(context.Context, *AckUpdate) (*Status, error)
	DeleteQueue(context.Context, *DeleteQueueInfo) (*Status, error)
	AddRoutingKey(context.Context, *AddRoute) (*Status, error)
	DeleteRoutingKey(context.Context, *DeleteRoute) (*Status, error)
	CreateUser(context.Context, *UserCreds) (*Status, error)
	SubmitBatchedMessages(context.Context, *BatchMessages) (*Status, error)
	IsLeaderNode(context.Context, *LeaderNodeRequest) (*Status, error)
	DeleteUser(context.Context, *UserInformation) (*Status, error)
	BatchAck(context.Context, *BatchAckUpdate) (*Status, error)
	BatchNack(context.Context, *BatchNackUpdate) (*Status, error)
	LogOut(context.Context, *LogOutRequest) (*LogOutResponse, error)
	CreateRole(context.Context, *CreateRoleRequest) (*CreateRoleResponse, error)
	AssignRole(context.Context, *AssignRoleRequest) (*AssignRoleResponse, error)
	UnassignRole(context.Context, *UnassignRoleRequest) (*UnassignRoleResponse, error)
	// contains filtered or unexported methods
}

type Message struct {
	Rk   string
	Data []byte
}

type MessageCollection struct {
	Messages []*MessageData `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

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

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

type PasswordManager interface {
	GetPassword(string) (string, error)
}

type QueueInfo struct {
	RoutingKey string `protobuf:"bytes,1,opt,name=routingKey,proto3" json:"routingKey,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Size       uint32 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	RetryLimit uint32 `protobuf:"varint,4,opt,name=retryLimit,proto3" json:"retryLimit,omitempty"`
	HasDLQueue bool   `protobuf:"varint,5,opt,name=hasDLQueue,proto3" json:"hasDLQueue,omitempty"`
	// contains filtered or unexported fields
}

type RequestMessageData struct {
	QueueName string `protobuf:"bytes,1,opt,name=queueName,proto3" json:"queueName,omitempty"`
	Amount    uint32 `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"`
	// contains filtered or unexported fields
}

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

type SyblineClient interface {
	SubmitMessage(ctx context.Context, routingKey string, data []byte) error
	SubmitBatchMessage(ctx context.Context, msg []Message) error
	GetMessages(ctx context.Context, queue string, amount uint32) ([]*MessageData, error)
	CreateQueue(ctx context.Context, routing, name string, size, retryLimit uint32, hasDLQ bool) error
	DeleteOueue(ctx context.Context, name string) error
	Ack(ctx context.Context, queue string, id []byte) error
	Login(ctx context.Context, username string) error
	ChangePassword(ctx context.Context, username, oldPassword, newPassword string) error
	Nack(ctx context.Context, queue string, id []byte) error
	AddRoutingKey(ctx context.Context, queue, routingKey string) error
	DeleteRoutingKey(ctx context.Context, queue, routingKey string) error
	CreateUser(ctx context.Context, username, password string) error
	DeleteUser(ctx context.Context, usernam string) error
	BatchAck(ctx context.Context, queue string, ids [][]byte) error
	BatchNack(ctx context.Context, queue string, ids [][]byte) error
	Consumer(capacity int, time time.Duration, queue string) (*syblineConsumer, error)
	Logout(ctx context.Context) error
	CreateRole(ctx context.Context, role string) error
	AssignRole(ctx context.Context, username, role string) error
	UnassignRole(ctx context.Context, username, role string) error
	Close()
}

type Timeout interface {
	Increment()
	Sleep()
	HasThreadReached() bool
}

type UnassignRoleRequest struct {
	Role     string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// contains filtered or unexported fields
}

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

type UnimplementedMQEndpointsServer struct {
}

type UniqueChannel struct {
	Ch chan *MessageData
	// contains filtered or unexported fields
}

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

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

type UserCreds struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

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