package messenger

import (
	"context"
	"gitee.com/anesec/chameleon/apis"
)

func newGRPC(options *messengerOptions) (Messenger, error) {
	return &grpc{}, nil
}

type grpc struct {
	endpoint       string
	pluginEndpoint string
}

func (msgr *grpc) Name() string {
	return GRPC
}

func (msgr *grpc) Messages(ctx context.Context, options ...FetchOption) (<-chan *apis.Message, <-chan error) {
	return nil, nil
}

func (msgr *grpc) Write(ctx context.Context, msg *apis.Message, options ...WriteOption) error {
	return nil
}

func (msgr *grpc) Close() error {
	return nil
}